如何增加 Spring 中的 Kafka 消费者

Question

我正在创建一个 Spring 支持 Kafka 的启动应用程序。 我创建了一个生产者和一个消费者，一切都很顺利。在运行时我有一个消费者。我想有很多消费者，我的主题的分区数量相同。

如何创建多个消费者？

我一直在搜索文档，但没有成功。

谢谢！

Answer 1

您需要创建一个ConcurrentKafkaListenerContainerFactory并设置并发参数。它根据并发性创建 1 个或多个 KafkaMessageListenerContainers。如果 ContainerProperties 配置了 TopicPartitions，则 TopicPartitions 会均匀分布在实例中。

例如

ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConcurrency(12);