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

Программисты JAVA общаются здесь
Anonymous
Интеграция сливающегося параллельного потребителя с Spring Kafka

Сообщение 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

Вернуться в «JAVA»