Class LogAndFailProcessingExceptionHandler

java.lang.Object
org.apache.kafka.streams.errors.LogAndFailProcessingExceptionHandler
All Implemented Interfaces:
Configurable, ProcessingExceptionHandler

public class LogAndFailProcessingExceptionHandler extends Object implements ProcessingExceptionHandler
Processing exception handler that logs a processing exception and then signals the processing pipeline to stop processing more records and fail.