Interface ContainerAwareBatchErrorHandler
- All Superinterfaces:
BatchErrorHandler,ConsumerAwareBatchErrorHandler,GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>
- All Known Subinterfaces:
ListenerInvokingBatchErrorHandler
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@Deprecated(since="2.8",
forRemoval=true)
@FunctionalInterface
public interface ContainerAwareBatchErrorHandler
extends ConsumerAwareBatchErrorHandler
Deprecated, for removal: This API element is subject to removal in a future version.
An error handler that has access to the batch of records from the last poll the
consumer, and the container.
- Since:
- 2.1
-
Method Summary
Modifier and TypeMethodDescriptiondefault voidhandle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) Deprecated, for removal: This API element is subject to removal in a future version.Handle the exception.voidhandle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.Handle the exception.default voidhandle(Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, Runnable invokeListener) Deprecated, for removal: This API element is subject to removal in a future version.Handle the exception.Methods inherited from interface org.springframework.kafka.listener.ConsumerAwareBatchErrorHandler
handleMethods inherited from interface org.springframework.kafka.listener.GenericErrorHandler
clearThreadState, isAckAfterHandle, setAckAfterHandle
-
Method Details
-
handle
default void handle(Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:GenericErrorHandlerHandle the exception.- Specified by:
handlein interfaceConsumerAwareBatchErrorHandler- Specified by:
handlein interfaceGenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>> - Parameters:
thrownException- The exception.data- the data.consumer- the consumer.
-
handle
void handle(Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container) Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:BatchErrorHandlerHandle the exception.- Specified by:
handlein interfaceBatchErrorHandler- Specified by:
handlein interfaceConsumerAwareBatchErrorHandler- Parameters:
thrownException- the exception.data- the consumer records.consumer- the consumer.container- the container.
-
handle
default void handle(Exception thrownException, @Nullable org.apache.kafka.clients.consumer.ConsumerRecords<?, ?> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MessageListenerContainer container, @Nullable Runnable invokeListener) Deprecated, for removal: This API element is subject to removal in a future version.Handle the exception.- Specified by:
handlein interfaceBatchErrorHandler- Parameters:
thrownException- the exception.data- the consumer records.consumer- the consumer.container- the container.invokeListener- a callback to re-invoke the listener.- Since:
- 2.3.7
-
CommonErrorHandler.