io.micronaut.configuration.kafka.exceptions

Class DefaultKafkaListenerExceptionHandler

java.lang.Object

io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler

All Implemented Interfaces:

KafkaListenerExceptionHandler, ExceptionHandler<KafkaListenerException>

@Singleton
 @Primary
public class DefaultKafkaListenerExceptionHandler
extends Object
implements KafkaListenerExceptionHandler

The default ExceptionHandler used when a KafkaConsumer fails to process a ConsumerRecord. By default just logs the error.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
DefaultKafkaListenerExceptionHandler()

Method Summary

Modifier and Type	Method and Description
void	handle(KafkaListenerException exception) Handle the given exception.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultKafkaListenerExceptionHandler

public DefaultKafkaListenerExceptionHandler()

Method Detail

handle

public void handle(KafkaListenerException exception)

Description copied from interface: ExceptionHandler

Handle the given exception.

Specified by:

handle in interface ExceptionHandler<KafkaListenerException>

Parameters:

exception - The exception to handle