springKafka监听器

anhgbhbe 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(512)

我用kafkalistener听多个主题，每个主题有20个分区，下面是我的配置。那么，每个主题是否共享相同的20个线程（或者）每个主题将拥有自己的20个线程？
导入org.springframework.kafka.annotation.kafkalistener；

KafkaListener(topics = { "topic1", "topic2","topic3"},
        concurrency = "20",
        clientIdPrefix = "client1",
        groupId = "group1")

1条答案

将有20个线程，每个线程消耗每个主题的一个分区。
如果需要单独的线程，可以添加3个 @KafkaListener 方法的注解，每个注解配置一个主题，或者将并发性设置为60，并使用自定义分区赋值器确保每个使用者只获得一个分区。