Estoy usando el KafkaMessageListenerContainer para consumir del tema kafka, tengo una lógica de aplicación para procesar cada registro que también depende de otros micro servicios. Ahora estoy confirmando manualmente el desplazamiento después de procesar cada registro.

Pero si la lógica de la aplicación falla, necesito buscar el desplazamiento fallido y seguir procesándolo hasta que tenga éxito. Para eso necesito hacer una búsqueda manual en tiempo de ejecución del último desplazamiento.

¿Ya es posible con KafkaMessageListenerContainer?