提问者:小点点

如何在Spring增加Kafka消费者


我正在创建一个支持Kafka的Spring Boot应用程序。我已经创建了一个生产者和一个消费者,一切都像魅力一样工作。在运行时,我有一个消费者。我想拥有许多消费者,与我的主题相同数量的分区。

如何创造众多消费者?

我一直在找留档,但没有成功。

谢谢你!


共1个答案

匿名用户

你需要创建一个ContranstKafkaListenerContainerFactory并设置并发参数。它会基于并发创建1个或多个KafkaMessageListenerContainers。如果ContainerProperties配置了TopicComptions,则TopicRantions会均匀分布在实例中。

举个例子

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