Interface ProcessingExceptionHandler

All Superinterfaces:

org.apache.kafka.common.Configurable

All Known Implementing Classes:

LogAndContinueProcessingExceptionHandler, LogAndFailProcessingExceptionHandler

public interface ProcessingExceptionHandler
extends org.apache.kafka.common.Configurable

An interface that allows user code to inspect a record that has failed processing

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ProcessingExceptionHandler.ProcessingHandlerResponse	Deprecated.
static class	ProcessingExceptionHandler.Response	Represents the result of handling a processing exception.
static enum	ProcessingExceptionHandler.Result	Enumeration that describes the response from the exception handler.

Method Summary

Modifier and Type	Method	Description
default ProcessingExceptionHandler.ProcessingHandlerResponse	handle(ErrorHandlerContext context, Record<?,?> record, Exception exception)	Deprecated. Use handleError(ErrorHandlerContext, Record, Exception) instead.
default ProcessingExceptionHandler.Response	handleError(ErrorHandlerContext context, Record<?,?> record, Exception exception)	Inspects a record and the exception received during processing.

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

configure

Method Details

handle

@Deprecated
default ProcessingExceptionHandler.ProcessingHandlerResponse handle(ErrorHandlerContext context,
 Record<?,?> record,
 Exception exception)

Deprecated.

Use handleError(ErrorHandlerContext, Record, Exception) instead.

Inspect a record and the exception received

Parameters:

context - Processing context metadata.

record - Record where the exception occurred.

exception - The actual exception.

Returns:

Whether to continue or stop processing.

handleError

default ProcessingExceptionHandler.Response handleError(ErrorHandlerContext context,
 Record<?,?> record,
 Exception exception)

Inspects a record and the exception received during processing.

Parameters:

context - Processing context metadata.

record - Record where the exception occurred.

exception - The actual exception.

Returns:

a ProcessingExceptionHandler.Response object