@Override
    public ProcessingHandlerResponse handle(final ErrorHandlerContext context, final Record<?, ?> record, final Exception exception) {
        log.error("Exception caught during message processing, " +
                "processor node: {}, taskId: {}, source topic: {}, source partition: {}, source offset: {}",
            context.processorNodeId(), context.taskId(), context.topic(), context.partition(), context.offset(),
            exception);

        return ProcessingHandlerResponse.FAIL;
    }
Processing exception handler that logs a processing exception and then
signals the processing pipeline to stop processing more records and fail.
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailProcessingExceptionHandler.java