@Override
    public Future<RecordMetadata> report(ProcessingContext<T> context) {
        if (!connConfig.enableErrorLog()) {
            return COMPLETED;
        }

        if (!context.failed()) {
            return COMPLETED;
        }

        log.error(message(context), context.error());
        errorHandlingMetrics.recordErrorLogged();
        return COMPLETED;
    }
Log error context.

@param context the processing context.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/LogReporter.java