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 enum	ProductionExceptionHandler.ProductionExceptionHandlerResponse

Method Summary

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.
default ProductionExceptionHandler.ProductionExceptionHandlerResponse	handleSerializationException(ProducerRecord record, Exception exception)	Handles serialization exception and determine if the process should continue.

Methods inherited from interface org.apache.kafka.common.Configurable

configure

Method Details

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 produce

exception - The exception that occurred during production

handleSerializationException

default ProductionExceptionHandler.ProductionExceptionHandlerResponse handleSerializationException(ProducerRecord record,
 Exception exception)

Handles serialization exception and determine if the process should continue. The default implementation is to fail the process.

Parameters:

record - the record that failed to serialize

exception - the exception that occurred during serialization