@FunctionalInterface public interface RemainingRecordsErrorHandler extends ConsumerAwareErrorHandler
| Modifier and Type | Method and Description |
|---|---|
default void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Handle the exception.
|
void |
handle(java.lang.Exception thrownException,
java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Handle the exception.
|
default void |
handle(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.
|
handleclearThreadStatedefault void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
GenericErrorHandlerhandle in interface ConsumerAwareErrorHandlerhandle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>thrownException - The exception.data - the data.consumer - the consumer.void handle(java.lang.Exception thrownException,
java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
thrownException - the exception.records - the remaining records including the one that failed.consumer - the consumer.default void handle(java.lang.Exception thrownException,
java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
MessageListenerContainer container)
ErrorHandlerhandle in interface ConsumerAwareErrorHandlerhandle in interface ErrorHandlerthrownException - the exception.records - the remaining records including the one that failed.consumer - the consumer.container - the container.