Class DeserializationExceptionHandler.Response

java.lang.Object

org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response

Enclosing interface:

DeserializationExceptionHandler

public static class DeserializationExceptionHandler.Response
extends Object

Represents the result of handling a deserialization exception.

The Response class encapsulates a DeserializationExceptionHandler.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<org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>>	deadLetterQueueRecords()	Retrieves an unmodifiable list of records to be sent to the dead letter queue.
static DeserializationExceptionHandler.Response	fail()	Creates a Response indicating that processing should fail.
static DeserializationExceptionHandler.Response	fail(List<org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>> deadLetterQueueRecords)	Creates a Response indicating that processing should fail.
DeserializationExceptionHandler.Result	result()	Retrieves the deserialization handler result.
static DeserializationExceptionHandler.Response	resume()	Creates a Response indicating that processing should continue.
static DeserializationExceptionHandler.Response	resume(List<org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>> deadLetterQueueRecords)	Creates a Response indicating that processing should continue.

Methods inherited from class java.lang.Object

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

Method Details

fail

public static DeserializationExceptionHandler.Response fail(List<org.apache.kafka.clients.producer.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 DeserializationExceptionHandler.Result.FAIL status.

fail

public static DeserializationExceptionHandler.Response fail()

Creates a Response indicating that processing should fail.

Returns:

a Response with a DeserializationExceptionHandler.Result.FAIL status.

resume

public static DeserializationExceptionHandler.Response resume(List<org.apache.kafka.clients.producer.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 DeserializationExceptionHandler.Result.RESUME status.

resume

public static DeserializationExceptionHandler.Response resume()

Creates a Response indicating that processing should continue.

Returns:

a Response with a DeserializationExceptionHandler.Result.RESUME status.

result

public DeserializationExceptionHandler.Result result()

Retrieves the deserialization handler result.

Returns:

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

deadLetterQueueRecords

public List<org.apache.kafka.clients.producer.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.