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.