@Singleton @Primary public class DefaultKafkaListenerExceptionHandler extends java.lang.Object implements KafkaListenerExceptionHandler
KafkaConsumer
fails to process a ConsumerRecord
. By default just logs the error.Constructor and Description |
---|
DefaultKafkaListenerExceptionHandler() |
Modifier and Type | Method and Description |
---|---|
void |
handle(KafkaListenerException exception) |
public DefaultKafkaListenerExceptionHandler()
public void handle(KafkaListenerException exception)
handle
in interface io.micronaut.core.exceptions.ExceptionHandler<KafkaListenerException>