public class BatchLoggingErrorHandler extends java.lang.Object implements BatchErrorHandler
LoggingErrorHandler
for each record.Constructor and Description |
---|
BatchLoggingErrorHandler() |
Modifier and Type | Method and Description |
---|---|
void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data)
Handle the exception.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handle
public void handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data)
GenericErrorHandler
handle
in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>
thrownException
- The exception.data
- the data.