public static LoggingContext forConnector(String connectorName) {
        Objects.requireNonNull(connectorName);
        LoggingContext context = new LoggingContext();
        MDC.put(CONNECTOR_CONTEXT, prefixFor(connectorName, Scope.WORKER, null));
        return context;
    }
@Test
    public void shouldNotAllowNullConnectorNameForConnectorContext() {
        assertThrows(NullPointerException.class, () -> LoggingContext.forConnector(null));
    }