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) |
public void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data)
handle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,?>>