Как Spring-Kafka Обрабатывает Сообщения И Мешает Ли Этому Автофиксация?

В предыдущей статье мы посмотрели, как это работает КафкаПотребитель и как реализован механизм автоматической фиксации.

В этой статье я хочу сосредоточиться на том, как принимаются и обрабатываются сообщения Spring-Kafka. Стоит отметить, что сейчас мы рассматриваем ситуацию с включить.

auto.commit = правда.

Согласно документации начиная с версии 2.3, для параметра auto.commit по умолчанию установлено значение false, хотя ранее это значение было похоже на значение по умолчанию в kafka-clients, т.е.

true. Это связано с тем, что контейнер KafkaMessageListenerContainer имеет собственные механизмы управления фиксациями.

Насколько это удобно и какие плюсы и минусы – пожалуй, тема отдельной статьи.

Поскольку контейнер прослушивателя имеет собственный механизм фиксации смещений, он предпочитает, чтобы Kafka ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG имел значение false. Начиная с версии 2.3, он безоговорочно устанавливает для него значение false, если только оно специально не установлено в фабрике-потребителе или в переопределении потребительского свойства контейнера.

1. Как Spring-Kafka работает с KafkaConsumer?
2. Каковы возможности параллельной обработки сообщений?
3. Что происходит, если при обработке сообщений возникают ошибки?

Прежде всего нам нужна конфигурация для подключения к теме:

   

 @Configuration
 public class KafkaConfig {
 
     @Bean
     KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer, String>>
                         myListenerContainerFactory() {
       ConcurrentKafkaListenerContainerFactory<Integer, String> factory =
                                 new ConcurrentKafkaListenerContainerFactory<>();
       factory.setConsumerFactory(consumerFactory());
 

   

• Обзор Ноутбука Dell Inspiron Series 1545-B64H32

  19 Oct, 24

• Объявлены Лучшие Нетбуки!

  19 Oct, 24

• Где Публиковать Свои Статьи

  19 Oct, 24

• Стартап Onwardmobility Отказывается От Планов По Выпуску 5G-Смартфона Blackberry - Android Police

  19 Oct, 24

• Цифровая Трансформация: Суперкомпьютеры Становятся Персональными, Модульными И Гибкими

  19 Oct, 24

• Убит Владелец Компьютерного Форума Ru-Board

  19 Oct, 24

• Как Назвать Космический Корабль Для Полета На Луну? Конкуренция Со Стороны Ркк «Энергия»

  19 Oct, 24

• Get-Запросы

  19 Oct, 24

• Мастер-Классы По Веб-Разработке

  19 Oct, 24

• 10 000 Долларов Сша За Лучшее Приложение Silverlight

  19 Oct, 24