Spring Kafka监听器

Question

我使用KafkaListener监听多个主题，每个主题有20个分区，下面是我的配置。那么，在这里，每个主题是否将共享相同的20个线程(或者)每个主题将获得自己的20个线程？

导入org.springframework.kafka.annotation.KafkaListener；

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

Answer 1

将有20个线程，每个线程消耗每个主题的一个分区。

如果您想要单独的线程，您可以在方法中添加3个@KafkaListener注释，每个注释配置一个主题，或者将并发数设置为60，并使用自定义分区分配器，以确保每个消费者只获得一个分区。