@FunctionalInterface public interface ConsumerAwareBatchErrorHandler extends BatchErrorHandler
| Modifier and Type | Method and Description |
|---|---|
default void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data)
Handle the exception.
|
void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Handle the exception.
|
default void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data)
GenericErrorHandlerhandle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>thrownException - The exception.data - the data.void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
GenericErrorHandlerhandle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>thrownException - The exception.data - the data.consumer - the consumer.