Class ProcessingExceptionHandler.Response

java.lang.Object

org.apache.kafka.streams.errors.ProcessingExceptionHandler.Response

Enclosing interface:

ProcessingExceptionHandler

public static class ProcessingExceptionHandler.Response
extends Object

Represents the result of handling a processing exception.

The Response class encapsulates a ProcessingExceptionHandler.Result, indicating whether processing should continue or fail, along with an optional list of ProducerRecord instances to be sent to a dead letter queue.

Method Summary

Modifier and Type	Method	Description
List<ProducerRecord<byte[],byte[]>>	deadLetterQueueRecords()	Retrieves an unmodifiable list of records to be sent to the dead letter queue.
static ProcessingExceptionHandler.Response	fail()	Creates a Response indicating that processing should fail.
static ProcessingExceptionHandler.Response	fail(List<ProducerRecord<byte[],byte[]>> deadLetterQueueRecords)	Creates a Response indicating that processing should fail.
ProcessingExceptionHandler.Result	result()	Retrieves the processing handler result.
static ProcessingExceptionHandler.Response	resume()	Creates a Response indicating that processing should continue.
static ProcessingExceptionHandler.Response	resume(List<ProducerRecord<byte[],byte[]>> deadLetterQueueRecords)	Creates a Response indicating that processing should continue.

Methods inherited from class Object

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

Method Details

fail

public static ProcessingExceptionHandler.Response fail(List<ProducerRecord<byte[],byte[]>> deadLetterQueueRecords)

Creates a Response indicating that processing should fail.

Parameters:

deadLetterQueueRecords - the list of records to be sent to the dead letter queue; may be null.

Returns:

a Response with a ProcessingExceptionHandler.Result.FAIL status.

fail

public static ProcessingExceptionHandler.Response fail()

Creates a Response indicating that processing should fail.

Returns:

a Response with a ProcessingExceptionHandler.Result.FAIL status.

resume

public static ProcessingExceptionHandler.Response resume(List<ProducerRecord<byte[],byte[]>> deadLetterQueueRecords)

Creates a Response indicating that processing should continue.

Parameters:

deadLetterQueueRecords - the list of records to be sent to the dead letter queue; may be null.

Returns:

a Response with a ProcessingExceptionHandler.Result.RESUME status.

resume

public static ProcessingExceptionHandler.Response resume()

Creates a Response indicating that processing should continue.

Returns:

a Response with a ProcessingExceptionHandler.Result.RESUME status.

result

public ProcessingExceptionHandler.Result result()

Retrieves the processing handler result.

Returns:

the ProcessingExceptionHandler.Result indicating whether processing should continue or fail.

deadLetterQueueRecords

public List<ProducerRecord<byte[],byte[]>> deadLetterQueueRecords()

Retrieves an unmodifiable list of records to be sent to the dead letter queue.

If the list is null, an empty list is returned.

Returns:

an unmodifiable list of ProducerRecord instances for the dead letter queue, or an empty list if no records are available.