Class LogAndFailExceptionHandler

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

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

      • LogAndFailExceptionHandler

        public LogAndFailExceptionHandler()