@FunctionalInterface public interface ConsumerAwareListenerErrorHandler extends KafkaListenerErrorHandler
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) throws java.lang.Exception
KafkaListenerErrorHandler
handleError
in interface KafkaListenerErrorHandler
message
- the spring-messaging message.exception
- the exception the listener threw, wrapped in a
ListenerExecutionFailedException
.@SendTo
annotation.java.lang.Exception
- an exception which may be the original or different.java.lang.Object handleError(org.springframework.messaging.Message<?> message, ListenerExecutionFailedException exception, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
KafkaListenerErrorHandler
handleError
in interface KafkaListenerErrorHandler
message
- the spring-messaging message.exception
- the exception the listener threw, wrapped in a
ListenerExecutionFailedException
.consumer
- the consumer.@SendTo
annotation.