温馨提示:本文翻译自stackoverflow.com,查看原文请点击:其他 - How to increase the Kafka consumers in Spring
apache-kafka spring-boot spring-kafka kafka-consumer-api

其他 - Spring 如何增加Kafka消费者

发布于 2020-03-27 11:52:37

我正在创建一个具有Kafka支持的Spring Boot应用程序。我创建了一个生产者和一个消费者,并且一切都像魅力一样运转。在运行时,我有一个使用者。我希望有很多消费者,主题的分区数量相同。

如何建立许多消费者?

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

谢谢 !

查看更多

查看更多

提问者
Nebrass Lamouchi
被浏览
152
victor gallet 2019-07-03 23:26

您需要创建一个ConcurrentKafkaListenerContainerFactory并设置并发参数。KafkaMessageListenerContainers基于并发创建1个或多个如果ContainerProperties配置了TopicPartitions,则TopicPartitions在实例之间平均分配。

例如

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