@FunctionalInterface public interface ConsumerAwareListenerErrorHandler extends KafkaListenerErrorHandler
SeekToCurrentErrorHandler for such situations.| Modifier and Type | Method and Description |
|---|---|
default java.lang.Object |
handleError(org.springframework.messaging.Message<?> message,
ListenerExecutionFailedException exception)
Handle the error.
|
java.lang.Object |
handleError(org.springframework.messaging.Message<?> message,
ListenerExecutionFailedException exception,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Handle the error.
|
default java.lang.Object handleError(org.springframework.messaging.Message<?> message,
ListenerExecutionFailedException exception)
KafkaListenerErrorHandlerhandleError in interface KafkaListenerErrorHandlermessage - the spring-messaging message.exception - the exception the listener threw, wrapped in a
ListenerExecutionFailedException.@SendTo annotation.java.lang.Object handleError(org.springframework.messaging.Message<?> message,
ListenerExecutionFailedException exception,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
KafkaListenerErrorHandlerhandleError in interface KafkaListenerErrorHandlermessage - the spring-messaging message.exception - the exception the listener threw, wrapped in a
ListenerExecutionFailedException.consumer - the consumer.@SendTo annotation.