Interface ConsumerAwareBatchErrorHandler
-
- All Superinterfaces:
BatchErrorHandler,GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>
- All Known Subinterfaces:
ContainerAwareBatchErrorHandler,ListenerInvokingBatchErrorHandler
- All Known Implementing Classes:
SeekToCurrentBatchErrorHandler
- 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 ConsumerAwareBatchErrorHandler extends BatchErrorHandler
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 voidhandle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data)Handle the exception.voidhandle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)Handle the exception.default voidhandle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)Handle the exception.-
Methods inherited from interface org.springframework.kafka.listener.BatchErrorHandler
handle
-
Methods inherited from interface org.springframework.kafka.listener.GenericErrorHandler
clearThreadState, isAckAfterHandle, setAckAfterHandle
-
-
-
-
Method Detail
-
handle
default void handle(java.lang.Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data)Description copied from interface:GenericErrorHandlerHandle the exception.- Specified by:
handlein interfaceGenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>- Parameters:
thrownException- The exception.data- the data.
-
handle
void handle(java.lang.Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)Description copied from interface:GenericErrorHandlerHandle the exception.- Specified by:
handlein interfaceGenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>- Parameters:
thrownException- The exception.data- the data.consumer- the consumer.
-
handle
default void handle(java.lang.Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)Description copied from interface:BatchErrorHandlerHandle the exception.- Specified by:
handlein interfaceBatchErrorHandler- Parameters:
thrownException- the exception.data- the consumer records.consumer- the consumer.container- the container.
-
-