Spring Kafka - потребитель, контейнер и слушатель

Question

Что это за классы?Я читаю об этом весь день и не могу понять из этого.Как именно он подключается к логическому потребителю Kafka?

Что именно является логическим потребителем, который может потреблять из одного раздела (это KafkaListener?).Если я хочу создать несколько потребителей, что мне делать, я должен создать больше @KafkaListeners.Нужно ли указывать @KafkaListener для каждого раздела.Или я могу решить это как-то с помощью ConcurrentMessageListenerContainer?Или я должен запустить весь контекст несколько раз?

Я полностью не понимаю.

Answer 1

Если вы используете опцию по умолчанию и аннотацию 'KafkaListenenr', она будет работать с One KafkaConsumer, но вы используете ConcurrentMessageListenerContainer и свойство параллелизма, превышающее размер раздела темы, она будет работать с несколькими потребителями

Если вы установите параллелизм,создайте контейнер KafkaMessageListenerContainer с получателем такого размера.(https://github.com/spring-projects/spring-kafka/blob/master/spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java#L149)

ссылка: https://docs.spring.io/spring-kafka/reference/htmlsingle/#_concurrentmessagelistenercontainer