Spring kafka, потребляющий одну партию, извлекает данные из разных разделов.

Question

У нас есть 1 тема с 3 разделами с одним потребителем.Мы используем данные в виде пакетов (25), используя аннотацию KafkaListener для Spring.Иногда мы видим, что за один прием 25 сообщений поступают данные из разных разделов.

Ожидается ли поведение пружины?Если да, то как работает коммит?Spring позаботится о фиксации всех разделов, когда мы вызовем метод acceptle () с ручной фиксацией.

Answer 1

Это не весна, это Кафка;Вот как это работает.

Вы должны подтвердить каждое сообщение, но, да, контейнер позаботится о коммитах.

Вы можете установить max.poll.records в 1, если вы хотите только сообщениеиз одного раздела.

Кстати, совсем не принято проверять вручную;Обычно предпочтительно, чтобы контейнер позаботился о смещениях, используя AckMode.BATCH или AckMode.RECORD.