Class LogAndContinueProcessingExceptionHandler
java.lang.Object
org.apache.kafka.streams.errors.LogAndContinueProcessingExceptionHandler
- All Implemented Interfaces:
org.apache.kafka.common.Configurable,ProcessingExceptionHandler
public class LogAndContinueProcessingExceptionHandlerextends Object implements ProcessingExceptionHandler
Processing exception handler that logs a processing 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.ProcessingExceptionHandler
ProcessingExceptionHandler.ProcessingHandlerResponse, ProcessingExceptionHandler.Response, ProcessingExceptionHandler.ResultConstructor Summary
ConstructorsMethod Summary
Modifier and TypeMethodDescriptionvoidhandleError(ErrorHandlerContext context, Record<?, ?> record, Exception exception) Inspects a record and the exception received during processing.Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.kafka.streams.errors.ProcessingExceptionHandler
handle
Constructor Details
LogAndContinueProcessingExceptionHandler
public LogAndContinueProcessingExceptionHandler()
Method Details
handleError
public ProcessingExceptionHandler.Response handleError(ErrorHandlerContext context, Record<?, ?> record, Exception exception) Description copied from interface:ProcessingExceptionHandlerInspects a record and the exception received during processing.- Specified by:
handleErrorin interfaceProcessingExceptionHandler- Parameters:
context- Processing context metadata.record- Record where the exception occurred.exception- The actual exception.- Returns:
- a
ProcessingExceptionHandler.Responseobject
configure