public class LoggingErrorHandler extends java.lang.Object implements ErrorHandler
ErrorHandler implementation for logging purpose.| Constructor and Description |
|---|
LoggingErrorHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
Handle the exception.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waithandleclearThreadState, handle, isAckAfterHandle, setAckAfterHandlepublic void handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record)
GenericErrorHandlerhandle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>thrownException - The exception.record - the data.