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.ProcessingHandlerResponseConstructor Summary
ConstructorsMethod Summary
Modifier and TypeMethodDescriptionvoidhandle(ErrorHandlerContext context, Record<?, ?> record, Exception exception) Inspect a record and the exception received
Constructor Details
LogAndContinueProcessingExceptionHandler
public LogAndContinueProcessingExceptionHandler()
Method Details
handle
public ProcessingExceptionHandler.ProcessingHandlerResponse handle(ErrorHandlerContext context, Record<?, ?> record, Exception exception) Description copied from interface:ProcessingExceptionHandlerInspect a record and the exception received- Specified by:
handlein interfaceProcessingExceptionHandler- Parameters:
context- Processing context metadata.record- Record where the exception occurred.exception- The actual exception.- Returns:
- Whether to continue or stop processing.
configure