@FunctionalInterface public interface ContainerAwareErrorHandler extends RemainingRecordsErrorHandler
Modifier and Type | Method and Description |
---|---|
default void |
handle(java.lang.Exception thrownException,
java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Handle the exception.
|
void |
handle(java.lang.Exception thrownException,
java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container)
Handle the exception.
|
handle
handle
clearThreadState, isAckAfterHandle
default void handle(java.lang.Exception thrownException, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
RemainingRecordsErrorHandler
handle
in interface RemainingRecordsErrorHandler
thrownException
- the exception.records
- the remaining records including the one that failed.consumer
- the consumer.void handle(java.lang.Exception thrownException, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)
ErrorHandler
handle
in interface ConsumerAwareErrorHandler
handle
in interface ErrorHandler
handle
in interface RemainingRecordsErrorHandler
thrownException
- the exception.records
- the remaining records including the one that failed.consumer
- the consumer.container
- the container.