Interface ContainerAwareErrorHandler
-
- All Superinterfaces:
ConsumerAwareErrorHandler,ErrorHandler,GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>,RemainingRecordsErrorHandler
- All Known Implementing Classes:
ConditionalDelegatingErrorHandler,ContainerStoppingErrorHandler,SeekToCurrentErrorHandler
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface ContainerAwareErrorHandler extends RemainingRecordsErrorHandler
An error handler that has access to the unprocessed records from the last poll (including the failed record), the consumer, and the container. The records passed to the handler will not be passed to the listener (unless re-fetched if the handler performs seeks).- Since:
- 2.1
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default voidhandle(java.lang.Exception thrownException, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)Handle the exception.voidhandle(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.-
Methods inherited from interface org.springframework.kafka.listener.ConsumerAwareErrorHandler
handle
-
Methods inherited from interface org.springframework.kafka.listener.GenericErrorHandler
clearThreadState, isAckAfterHandle, setAckAfterHandle
-
Methods inherited from interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
handle
-
-
-
-
Method Detail
-
handle
default void handle(java.lang.Exception thrownException, @Nullable java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)Description copied from interface:RemainingRecordsErrorHandlerHandle the exception. The failed record is the first in the list.- Specified by:
handlein interfaceRemainingRecordsErrorHandler- Parameters:
thrownException- the exception.records- the remaining records including the one that failed.consumer- the consumer.
-
handle
void handle(java.lang.Exception thrownException, @Nullable java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)Description copied from interface:ErrorHandlerHandle the exception.- Specified by:
handlein interfaceConsumerAwareErrorHandler- Specified by:
handlein interfaceErrorHandler- Specified by:
handlein interfaceRemainingRecordsErrorHandler- Parameters:
thrownException- the exception.records- the remaining records including the one that failed.consumer- the consumer.container- the container.
-
-