Package org.apache.kafka.streams.errors

Class LogAndContinueExceptionHandler

java.lang.Object

org.apache.kafka.streams.errors.LogAndContinueExceptionHandler

All Implemented Interfaces:

Configurable, DeserializationExceptionHandler

public class LogAndContinueExceptionHandler
extends Object
implements DeserializationExceptionHandler

Deserialization handler that logs a deserialization exception and then signals the processing pipeline to continue processing more records.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.kafka.streams.errors.DeserializationExceptionHandler

DeserializationExceptionHandler.DeserializationHandlerResponse

Constructor Summary

Constructors

Constructor	Description
LogAndContinueExceptionHandler()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs)	Configure this class with the given key-value pairs
DeserializationExceptionHandler.DeserializationHandlerResponse	handle(ErrorHandlerContext context, ConsumerRecord<byte[],byte[]> record, Exception exception)	Inspect a record and the exception received.
DeserializationExceptionHandler.DeserializationHandlerResponse	handle(ProcessorContext context, ConsumerRecord<byte[],byte[]> record, Exception exception)	Deprecated. Since 3.9.

Methods inherited from class java.lang.Object

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

Constructor Details

LogAndContinueExceptionHandler

public LogAndContinueExceptionHandler()

Method Details

handle

@Deprecated
public DeserializationExceptionHandler.DeserializationHandlerResponse handle(ProcessorContext context,
 ConsumerRecord<byte[],byte[]> record,
 Exception exception)

Deprecated.

Since 3.9. Use handle(ErrorHandlerContext, ConsumerRecord, Exception) instead.

Description copied from interface: DeserializationExceptionHandler

Inspect a record and the exception received.

Note, that the passed in ProcessorContext only allows to access metadata like the task ID. However, it cannot be used to emit records via ProcessorContext.forward(Object, Object); calling forward() (and some other methods) would result in a runtime exception.

Specified by:

handle in interface DeserializationExceptionHandler

Parameters:

context - Processor context.

record - Record that failed deserialization.

exception - The actual exception.

Returns:

Whether to continue or stop processing.

handle

public DeserializationExceptionHandler.DeserializationHandlerResponse handle(ErrorHandlerContext context,
 ConsumerRecord<byte[],byte[]> record,
 Exception exception)

Description copied from interface: DeserializationExceptionHandler

Inspect a record and the exception received.

Specified by:

handle in interface DeserializationExceptionHandler

Parameters:

context - Error handler context.

record - Record that failed deserialization.

exception - The actual exception.

Returns:

Whether to continue or stop processing.

configure

public void configure(Map<String,?> configs)

Description copied from interface: Configurable

Configure this class with the given key-value pairs

Specified by:

configure in interface Configurable