我正在创建一个支持Kafka的Spring Boot应用程序。我已经创建了一个生产者和一个消费者,一切都像魅力一样工作。在运行时,我有一个消费者。我想拥有许多消费者,与我的主题相同数量的分区。
如何创造众多消费者?
我一直在找留档,但没有成功。
谢谢你!
你需要创建一个ContranstKafkaListenerContainerFactory
并设置并发参数。它会基于并发创建1个或多个KafkaMessageListenerContainers
。如果ContainerProperties
配置了TopicComptions,则TopicRantions会均匀分布在实例中。
举个例子
ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConcurrency(12);