org.apache.kafka.streams.errors

Class LogAndFailExceptionHandler

java.lang.Object

org.apache.kafka.streams.errors.LogAndFailExceptionHandler

All Implemented Interfaces:

org.apache.kafka.common.Configurable, DeserializationExceptionHandler

public class LogAndFailExceptionHandler
extends Object
implements DeserializationExceptionHandler

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

Nested Class Summary

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

DeserializationExceptionHandler.DeserializationHandlerResponse

Constructor Summary

Constructors

Constructor and Description
LogAndFailExceptionHandler()

Method Summary

Modifier and Type	Method and Description
void	configure(Map<String,?> configs)
DeserializationExceptionHandler.DeserializationHandlerResponse	handle(ProcessorContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, Exception exception) Inspect a record and the exception received.

Methods inherited from class java.lang.Object

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

Constructor Detail

LogAndFailExceptionHandler

public LogAndFailExceptionHandler()

Method Detail

handle

public DeserializationExceptionHandler.DeserializationHandlerResponse handle(ProcessorContext context,
                                                                             org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record,
                                                                             Exception exception)

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

configure

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

Specified by:

configure in interface org.apache.kafka.common.Configurable