org.apache.kafka.streams.errors

Class DefaultProductionExceptionHandler

java.lang.Object

org.apache.kafka.streams.errors.DefaultProductionExceptionHandler

All Implemented Interfaces:

org.apache.kafka.common.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 and Description
DefaultProductionExceptionHandler()

Method Summary

Modifier and Type	Method and Description
void	configure(Map<String,?> configs)
ProductionExceptionHandler.ProductionExceptionHandlerResponse	handle(org.apache.kafka.clients.producer.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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultProductionExceptionHandler

public DefaultProductionExceptionHandler()

Method Detail

handle

public ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(org.apache.kafka.clients.producer.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 interface ProductionExceptionHandler

Parameters:

record - The record that failed to produce

exception - The exception that occurred during production

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable