Interface ConsumerAwareErrorHandler
-
- All Superinterfaces:
ErrorHandler
,GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
- All Known Subinterfaces:
ContainerAwareErrorHandler
,RemainingRecordsErrorHandler
- All Known Implementing Classes:
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 ConsumerAwareErrorHandler extends ErrorHandler
An error handler that has access to the consumer, for example to adjust offsets after an error.- Since:
- 2.0
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default void
handle(java.lang.Exception thrownException, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)
Handle the exception.default void
handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data)
Handle the exception.void
handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Handle the exception.-
Methods inherited from interface org.springframework.kafka.listener.GenericErrorHandler
clearThreadState, isAckAfterHandle, setAckAfterHandle
-
-
-
-
Method Detail
-
handle
default void handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data)
Description copied from interface:GenericErrorHandler
Handle the exception.- Specified by:
handle
in interfaceGenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
- Parameters:
thrownException
- The exception.data
- the data.
-
handle
void handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Description copied from interface:GenericErrorHandler
Handle the exception.- Specified by:
handle
in interfaceGenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
- Parameters:
thrownException
- The exception.data
- the data.consumer
- the consumer.
-
handle
default void handle(java.lang.Exception thrownException, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)
Description copied from interface:ErrorHandler
Handle the exception.- Specified by:
handle
in interfaceErrorHandler
- Parameters:
thrownException
- the exception.data
- the remaining records including the one that failed.consumer
- the consumer.container
- the container.
-
-