Интеграция сливающегося параллельного потребителя с Spring Kafka ⇐ JAVA

[Anonymous]

В нашем приложении мы в настоящее время используем Spring boot Kafka для потребления сообщений из Kafka с помощью «ConcurrentKafkaListenerContainerFactory», где мы установили значение параллелизма, равное количеству разделов в теме Kafka.
I' Я изучаю некоторые библиотеки, такие как https://github.com/confluentinc/parallel-consumer, чтобы увеличить параллелизм. У меня мало вопросов по этому поводу.

• Хотя я это читал, конфлюентный параллельный потребитель может увеличить параллелизм, разве мы не можем получить то же самое с ConcurrentKafkaListenerContainerFactory?
  Мы используем «@KafkaListener» для обработки сообщений. Можем ли мы продолжать использовать то же самое с библиотекой параллельного потребителя. Я вижу проблемы с интеграцией, как упомянуто здесь - https://github.com/confluentinc/paralle ... ssions/671 и параллельный потребитель с весенней загрузкой.
  Хотя я знаю, это зависит исключительно от варианта использования, следует ли выберите «параллельный потребитель» или «Spring Kafka», они оба дополняют друг друга или нам нужно использовать их независимо?

Подробнее здесь: https://stackoverflow.com/questions/789 ... ring-kafka