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
static enum	ProductionExceptionHandler.SerializationExceptionOrigin

Method Summary

Modifier and Type	Method	Description
default ProductionExceptionHandler.ProductionExceptionHandlerResponse	handle(ProducerRecord<byte[],byte[]> record, Exception exception)	Deprecated. Since 3.9.
default ProductionExceptionHandler.ProductionExceptionHandlerResponse	handle(ErrorHandlerContext context, 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 to continue or stop processing.
default ProductionExceptionHandler.ProductionExceptionHandlerResponse	handleSerializationException(ProducerRecord record, Exception exception)	Deprecated. Since 3.9.
default ProductionExceptionHandler.ProductionExceptionHandlerResponse	handleSerializationException(ErrorHandlerContext context, ProducerRecord record, Exception exception, ProductionExceptionHandler.SerializationExceptionOrigin origin)	Handles serialization exception and determine if the process should continue.

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

configure

Method Details

handle

@Deprecated
default ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(ProducerRecord<byte[],byte[]> record,
 Exception exception)

Deprecated.

Since 3.9. Use handle(ErrorHandlerContext, ProducerRecord, Exception) instead.

Inspect a record that we attempted to produce, and the exception that resulted from attempting to produce it and determine to continue or stop processing.

Parameters:

record - The record that failed to produce.

exception - The exception that occurred during production.

Returns:

Whether to continue or stop processing, or retry the failed operation.

handle

default ProductionExceptionHandler.ProductionExceptionHandlerResponse handle(ErrorHandlerContext context,
 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 to continue or stop processing.

Parameters:

context - The error handler context metadata.

record - The record that failed to produce.

exception - The exception that occurred during production.

Returns:

Whether to continue or stop processing, or retry the failed operation.

handleSerializationException

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

Deprecated.

Since 3.9. Use handleSerializationException(ErrorHandlerContext, ProducerRecord, Exception, SerializationExceptionOrigin) instead.

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.

Returns:

Whether to continue or stop processing, or retry the failed operation.

handleSerializationException

default ProductionExceptionHandler.ProductionExceptionHandlerResponse handleSerializationException(ErrorHandlerContext context,
 ProducerRecord record,
 Exception exception,
 ProductionExceptionHandler.SerializationExceptionOrigin origin)

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

Parameters:

context - The error handler context metadata.

record - The record that failed to serialize.

exception - The exception that occurred during serialization.

origin - The origin of the serialization exception.

Returns:

Whether to continue or stop processing, or retry the failed operation.