Package org.apache.kafka.streams.errors
Interface ProductionExceptionHandler
-
- All Superinterfaces:
Configurable
- All Known Implementing Classes:
DefaultProductionExceptionHandler
public interface ProductionExceptionHandler extends Configurable
Interface that specifies how an exception when attempting to produce a result to Kafka should be handled.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
ProductionExceptionHandler.ProductionExceptionHandlerResponse
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ProductionExceptionHandler.ProductionExceptionHandlerResponse
handle(ProducerRecord<byte[],byte[]> record, 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.-
Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
-
-
-
Method Detail
-
handle
ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(ProducerRecord<byte[],byte[]> record, 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 produceexception
- The exception that occurred during production
-
-