Class BatchLoggingErrorHandler

    • Constructor Detail

      • BatchLoggingErrorHandler

        public BatchLoggingErrorHandler()
    • Method Detail

      • handle

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