@FunctionalInterface public interface ListenerInvokingBatchErrorHandler extends ContainerAwareBatchErrorHandler
| Modifier and Type | Method and Description |
|---|---|
default void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container)
Handle the exception.
|
void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container,
java.lang.Runnable invokeListener)
Handle the exception.
|
handlehandleclearThreadState, isAckAfterHandle, setAckAfterHandledefault void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container)
BatchErrorHandlerhandle in interface BatchErrorHandlerhandle in interface ConsumerAwareBatchErrorHandlerhandle in interface ContainerAwareBatchErrorHandlerthrownException - the exception.data - the consumer records.consumer - the consumer.container - the container.void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container,
java.lang.Runnable invokeListener)
ContainerAwareBatchErrorHandlerhandle in interface BatchErrorHandlerhandle in interface ContainerAwareBatchErrorHandlerthrownException - the exception.records - the consumer records.consumer - the consumer.container - the container.invokeListener - a callback to re-invoke the listener.