Class LogAndContinueExceptionHandler
java.lang.Object
org.apache.kafka.streams.errors.LogAndContinueExceptionHandler
- All Implemented Interfaces:
org.apache.kafka.common.Configurable, DeserializationExceptionHandler
public class LogAndContinueExceptionHandlerextends 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 DeserializationExceptionHandler
DeserializationExceptionHandler.DeserializationHandlerResponse, DeserializationExceptionHandler.Response, DeserializationExceptionHandler.ResultConstructor Summary
ConstructorsMethod Summary
Modifier and TypeMethodDescriptionvoidhandleError(ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[], byte[]> record, Exception exception) Inspects a record and the exception received during deserialization.Methods inherited from class Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface DeserializationExceptionHandler
handle, handle
Constructor Details
LogAndContinueExceptionHandler
public LogAndContinueExceptionHandler()
Method Details
handleError
public DeserializationExceptionHandler.Response handleError(ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[], byte[]> record, Exception exception) Description copied from interface:DeserializationExceptionHandlerInspects a record and the exception received during deserialization.- Specified by:
handleErrorin interfaceDeserializationExceptionHandler- Parameters:
context- Error handler context.record- Record that failed deserialization.exception- The actual exception.- Returns:
- a
DeserializationExceptionHandler.Responseobject
configure