ользую KafkaMessageListenerContainer для использования из темы kafka, у меня есть логика приложения для обработки каждой записи, которая также зависит от других микро сервисов. Сейчас я вручную фиксирую смещение после обработки каждой записи.

Но если у меня не получается логика приложения, мне нужно искать сбойное смещение и продолжать его обрабатывать до тех пор, пока оно не будет успешным. Для этого мне нужно выполнить поиск во время выполнения последнего смещения.

Возможно ли это с KafkaMessageListenerContainer?