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 and Description
static class	ProductionExceptionHandler.ProductionExceptionHandlerResponse

Method Summary

Modifier and Type	Method and 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 Detail

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