Package org.apache.kafka.streams.errors
Class DefaultProductionExceptionHandler
- java.lang.Object
-
- org.apache.kafka.streams.errors.DefaultProductionExceptionHandler
-
- All Implemented Interfaces:
Configurable
,ProductionExceptionHandler
public class DefaultProductionExceptionHandler extends Object implements ProductionExceptionHandler
ProductionExceptionHandler
that always instructs streams to fail when an exception happens while attempting to produce result records.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.kafka.streams.errors.ProductionExceptionHandler
ProductionExceptionHandler.ProductionExceptionHandlerResponse
-
-
Constructor Summary
Constructors Constructor Description DefaultProductionExceptionHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configure(Map<String,?> configs)
Configure this class with the given key-value pairsProductionExceptionHandler.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.
-
-
-
Method Detail
-
handle
public ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(ProducerRecord<byte[],byte[]> record, 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 interfaceProductionExceptionHandler
- Parameters:
record
- The record that failed to produceexception
- The exception that occurred during production
-
configure
public void configure(Map<String,?> configs)
Description copied from interface:Configurable
Configure this class with the given key-value pairs- Specified by:
configure
in interfaceConfigurable
-
-