public class SeekToCurrentErrorHandler extends java.lang.Object implements ContainerAwareErrorHandler
| Constructor and Description |
|---|
SeekToCurrentErrorHandler() |
| Modifier and Type | Method and Description |
|---|---|
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandlehandlehandlepublic 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 ContainerAwareErrorHandlerhandle in interface ErrorHandlerhandle in interface RemainingRecordsErrorHandlerthrownException - the exception.records - the remaining records including the one that failed.consumer - the consumer.container - the container.