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(ProcessorContext context, ConsumerRecord<byte[],byte[]> record, Exception exception)`	Inspect a record and the exception received.

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

Constructor Details
- LogAndContinueExceptionHandler
  
  public LogAndContinueExceptionHandler()
Method Details
- handle
  
  public DeserializationExceptionHandler.DeserializationHandlerResponse handle(ProcessorContext context, 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)
  
  Description copied from interface: Configurable
  
  Configure this class with the given key-value pairs
  
  Specified by:
  
  configure in interface Configurable

Class LogAndContinueExceptionHandler