public static LoggingContext forOffsets(ConnectorTaskId id) {
        Objects.requireNonNull(id);
        LoggingContext context = new LoggingContext();
        MDC.put(CONNECTOR_CONTEXT, prefixFor(id.connector(), Scope.OFFSETS, id.task()));
        return context;
    }
@Test
    public void shouldNotAllowNullTaskIdForOffsetContext() {
        assertThrows(NullPointerException.class, () -> LoggingContext.forOffsets(null));
    }