public class ContainerStoppingBatchErrorHandler extends KafkaExceptionLogLevelAware implements ContainerAwareBatchErrorHandler
| Constructor and Description |
|---|
ContainerStoppingBatchErrorHandler()
Construct an instance with a
SimpleAsyncTaskExecutor. |
ContainerStoppingBatchErrorHandler(java.util.concurrent.Executor executor)
Construct an instance with the provided
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.
|
getLogLevel, setLogLevelclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandle, handlehandleclearThreadState, isAckAfterHandle, setAckAfterHandlepublic ContainerStoppingBatchErrorHandler()
SimpleAsyncTaskExecutor.public ContainerStoppingBatchErrorHandler(java.util.concurrent.Executor executor)
Executor.executor - the executor.public 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.