Class LoggingErrorHandler

  • All Implemented Interfaces:
    ErrorHandler, GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,​?>>

    public class LoggingErrorHandler
    extends java.lang.Object
    implements ErrorHandler
    The ErrorHandler implementation for logging purpose.
    Author:
    Marius Bogoevici, Gary Russell
    • Constructor Detail

      • LoggingErrorHandler

        public LoggingErrorHandler()
    • Method Detail

      • handle

        public void handle​(java.lang.Exception thrownException,
                           org.apache.kafka.clients.consumer.ConsumerRecord<?,​?> record)
        Description copied from interface: GenericErrorHandler
        Handle the exception.
        Specified by:
        handle in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,​?>>
        Parameters:
        thrownException - The exception.
        record - the data.