Каков идеальный способ хранения потребительского смещения с помощью клиентского клиентского загрузчика kafka?

Question

Весенняя кафка у меня потребительское приложение. Приложение действует как проход, через который опрашивает сообщения от брокера kafka и отправляет их в IBM MQ. Каков наилучший / упрощенный подход для хранения смещения в случае сбоя?

Answer 1

Самый простой подход - использовать механизм по умолчанию для хранения смещений в самой kafka.

Если вы добавите SeekToCurrentErrorHandler, контейнер продолжит повторную доставку записей, которые не удалось выполнить в прослушивателе, по умолчанию до 10 раз, но его можно настроить для бесконечных повторных попыток.

Если вы добавите повторение с отслеживанием состояния, адаптер слушателя может добавить задержку между каждой попыткой доставки.

См. Состояние с повторной попыткой .

ackOnError должен быть установлен на false.