Class DefaultProductionExceptionHandler

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

    public class DefaultProductionExceptionHandler
    extends java.lang.Object
    implements ProductionExceptionHandler
    ProductionExceptionHandler that always instructs streams to fail when an exception happens while attempting to produce result records.
    • Constructor Detail

      • DefaultProductionExceptionHandler

        public DefaultProductionExceptionHandler()
    • Method Detail

      • handle

        public ProductionExceptionHandler.ProductionExceptionHandlerResponse handle​(org.apache.kafka.clients.producer.ProducerRecord<byte[],​byte[]> record,
                                                                                    java.lang.Exception exception)
        Description copied from interface: ProductionExceptionHandler
        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.
        Specified by:
        handle in interface ProductionExceptionHandler
        Parameters:
        record - The record that failed to produce
        exception - The exception that occurred during production
      • configure

        public void configure​(java.util.Map<java.lang.String,​?> configs)
        Specified by:
        configure in interface org.apache.kafka.common.Configurable