Class LogAndContinueExceptionHandler

  • All Implemented Interfaces:
    org.apache.kafka.common.Configurable, DeserializationExceptionHandler

    public class LogAndContinueExceptionHandler
    extends java.lang.Object
    implements DeserializationExceptionHandler
    Deserialization handler that logs a deserialization exception and then signals the processing pipeline to continue processing more records.
    • Constructor Detail

      • LogAndContinueExceptionHandler

        public LogAndContinueExceptionHandler()