public class ContainerStoppingBatchErrorHandler extends java.lang.Object implements ContainerAwareBatchErrorHandler
Constructor and Description |
---|
ContainerStoppingBatchErrorHandler() |
ContainerStoppingBatchErrorHandler(java.util.concurrent.Executor executor) |
Modifier and Type | Method and Description |
---|---|
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handle
handle
clearThreadState, isAckAfterHandle
public ContainerStoppingBatchErrorHandler()
public ContainerStoppingBatchErrorHandler(java.util.concurrent.Executor executor)
public 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
handle
in interface ContainerAwareBatchErrorHandler
thrownException
- the exception.data
- the consumer records.consumer
- the consumer.container
- the container.