Package org.apache.kafka.streams.errors
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.
-
-
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(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.
-
-
-
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 produceexception
- The exception that occurred during production
-
-