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.

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