实例内的 KafkaListener 分区映射并发度 > 1

Question

我有一个简单的kafka监听器注释方法 和

spring.kafka.listener.concurrency = 5

我的主题有 100 个分区，并且有 5 个应用程序实例正在运行。 该主题设置了分区键，因此存在消费者级别分区亲和性。 我想了解消费者的多个线程是否可以从同一分区接收消息。

Answer 1

不；对于

concurrency = 5

，每个实例有 5 个不同的消费者；一组中只有一个消费者可以从分区中消费。