public interface BatchErrorHandler extends GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>
BatchMessageListener.
The listener should communicate which position(s) in the list failed in the
exception.| 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.
|
clearThreadState, handle, handle, isAckAfterHandledefault void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container)
thrownException - the exception.data - the consumer records.consumer - the consumer.container - the container.