Как увеличить потребителей Kafka весной

Question

Я создаю приложение Spring Boot с поддержкой Kafka.Я создал продюсера и потребителя, и все работает как шарм.Во время выполнения у меня есть один потребитель.Я хотел, чтобы у меня было много потребителей, столько же разделов в моей теме.

Как создать много потребителей?

Я искал в документации, но безуспешно.

Спасибо!

Answer 1

Вам необходимо создать ConcurrentKafkaListenerContainerFactory и установить параметр параллелизма. Создает 1 или более KafkaMessageListenerContainers на основе параллелизма. Если ContainerProperties настроен с TopicPartitions, TopicPartitions распределены равномерно по экземплярам.

Например

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