public static LoggingContext forConnector(String connectorName) {
        Objects.requireNonNull(connectorName);
        LoggingContext context = new LoggingContext();
        MDC.put(CONNECTOR_CONTEXT, prefixFor(connectorName, Scope.WORKER, null));
        return context;
    }
Modify the current {@link MDC} logging context to set the {@link #CONNECTOR_CONTEXT connector context} to include the
supplied name and the {@link Scope#WORKER} scope.

@param connectorName the connector name; may not be null
connect/runtime/src/main/java/org/apache/kafka/connect/util/LoggingContext.java