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, ProductionExceptionHandler.SerializationExceptionOrigin

Constructor Summary

Constructors

Constructor	Description
DefaultProductionExceptionHandler()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs)	Configure this class with the given key-value pairs
ProductionExceptionHandler.ProductionExceptionHandlerResponse	handle(ProducerRecord<byte[],byte[]> record, Exception exception)	Deprecated. Since 3.9.
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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.streams.errors.ProductionExceptionHandler

handleSerializationException, handleSerializationException

Constructor Details

DefaultProductionExceptionHandler

public DefaultProductionExceptionHandler()

Method Details

handle

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

Deprecated.

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

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 to continue or stop processing.

Specified by:

handle in interface ProductionExceptionHandler

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

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

Specified by:

handle in interface ProductionExceptionHandler

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.

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 interface Configurable