Interface DeserializationExceptionHandler

  • All Superinterfaces:
    org.apache.kafka.common.Configurable
    All Known Implementing Classes:
    LogAndContinueExceptionHandler, LogAndFailExceptionHandler

    public interface DeserializationExceptionHandler
    extends org.apache.kafka.common.Configurable
    Interface that specifies how an exception from source node deserialization (e.g., reading from Kafka) should be handled.