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

Constructor Summary

Constructors

Constructor	Description
DefaultProductionExceptionHandler()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs)
ProductionExceptionHandler.Response	handleError(ErrorHandlerContext context, 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 to continue or stop processing.
ProductionExceptionHandler.Response	handleSerializationError(ErrorHandlerContext context, org.apache.kafka.clients.producer.ProducerRecord record, Exception exception, ProductionExceptionHandler.SerializationExceptionOrigin origin)	Handles serialization exception and determine if the process should continue.

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

handle, handle, handleSerializationException, handleSerializationException

Constructor Details

DefaultProductionExceptionHandler

public DefaultProductionExceptionHandler()

Method Details

handleError

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

Specified by:

handleError 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:

a ProductionExceptionHandler.Response object

handleSerializationError

public ProductionExceptionHandler.Response handleSerializationError(ErrorHandlerContext context,
 org.apache.kafka.clients.producer.ProducerRecord record,
 Exception exception,
 ProductionExceptionHandler.SerializationExceptionOrigin origin)

Description copied from interface: ProductionExceptionHandler

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

Specified by:

handleSerializationError in interface ProductionExceptionHandler

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:

a ProductionExceptionHandler.Response object

configure

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

Specified by:

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