private String toString(ProcessingContext<T> context, boolean includeMessage) {
        StringBuilder builder = new StringBuilder();
        builder.append("Executing stage '");
        builder.append(context.stage().name());
        builder.append("' with class '");
        builder.append(context.executingClass() == null ? "null" : context.executingClass().getName());
        builder.append('\'');
        if (includeMessage) {
            appendMessage(builder, context.original());
        }
        builder.append('.');
        return builder.toString();
    }
Log error context.

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