Interface ProductionExceptionHandler

  • All Superinterfaces:
    org.apache.kafka.common.Configurable
    All Known Implementing Classes:
    DefaultProductionExceptionHandler

    public interface ProductionExceptionHandler
    extends org.apache.kafka.common.Configurable
    Interface that specifies how an exception when attempting to produce a result to Kafka should be handled.
    • Method Detail

      • handle

        ProductionExceptionHandler.ProductionExceptionHandlerResponse handle​(org.apache.kafka.clients.producer.ProducerRecord<byte[],​byte[]> record,
                                                                             java.lang.Exception exception)
        Inspect a record that we attempted to produce, and the exception that resulted from attempting to produce it and determine whether or not to continue processing.
        Parameters:
        record - The record that failed to produce
        exception - The exception that occurred during production