Spring viene con la función de manejo de excepciones de mensajes de Kafka

El método onMessage ejecutará el método especificado por la anotación @KafkaListener

Al informar una excepción, detectará la excepción y continuará procesando el siguiente mensaje. Si se establece la configuración de envío automático (auto-commitoffset). Kafka considerará esto El mensaje se consumió exitosamente

La clase de implementación de manejo de excepciones imprimirá el registro, nada más.