Весенний Кафка переигрывает старые сообщения

Question

У меня есть требование переигрывать старые смещения Кафки в случае любой проблемы. Есть ли весной доступный API Кафки для воспроизведения старого смещения темы?

Answer 1

Да, есть. Взгляните на ConsumerSeekAware . Использование описано здесь . А именно, об этом методе:

void registerSeekCallback(ConsumerSeekCallback callback);

в документации написано:

вызывается при запуске контейнера; этот обратный вызов должен быть использован при поиске в произвольное время после инициализации. Вам следует сохранить ссылку на обратный звонок; если вы используете тот же слушатель в нескольких контейнерах (или в ConcurrentMessageListenerContainer) Вы должны хранить обратный вызов в ThreadLocal или какой-либо другой структуре вводится слушателем Тема.

Сам обратный вызов задокументирован здесь .