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.