Interface ErrorHandler
- All Superinterfaces:
GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
- All Known Subinterfaces:
ConsumerAwareErrorHandler,ContainerAwareErrorHandler,RemainingRecordsErrorHandler
@Deprecated(since="2.8",
forRemoval=true)
public interface ErrorHandler
extends GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
Deprecated, for removal: This API element is subject to removal in a future version.
Handles errors thrown during the execution of a
MessageListener.-
Method Summary
Modifier and TypeMethodDescriptiondefault voidhandle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, 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.Methods inherited from interface org.springframework.kafka.listener.GenericErrorHandler
clearThreadState, handle, handle, isAckAfterHandle, setAckAfterHandle
-
Method Details
-
handle
default void handle(Exception thrownException, List<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, 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.- Parameters:
thrownException- the exception.records- the remaining records including the one that failed.consumer- the consumer.container- the container.
-
CommonErrorHandler.