Interface ProductionExceptionHandler

All Superinterfaces:
All Known Implementing Classes:

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

    • handle

      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.
      record - The record that failed to produce
      exception - The exception that occurred during production