@FunctionalInterface public interface ContainerAwareBatchErrorHandler extends ConsumerAwareBatchErrorHandler
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)
Handle the exception.
|
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.
|
default void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container,
java.lang.Runnable invokeListener)
Handle the exception.
|
handle
clearThreadState, isAckAfterHandle
default void handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
GenericErrorHandler
handle
in interface ConsumerAwareBatchErrorHandler
handle
in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>
thrownException
- The exception.data
- the data.consumer
- the consumer.void handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)
BatchErrorHandler
handle
in interface BatchErrorHandler
handle
in interface ConsumerAwareBatchErrorHandler
thrownException
- the exception.data
- the consumer records.consumer
- the consumer.container
- the container.default void handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, java.lang.Runnable invokeListener)
handle
in interface BatchErrorHandler
thrownException
- the exception.data
- the consumer records.consumer
- the consumer.container
- the container.invokeListener
- a callback to re-invoke the listener.