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