private void awaitStopConnectors(Collection<String> ids) {
        long now = time.milliseconds();
        long deadline = now + CONNECTOR_GRACEFUL_SHUTDOWN_TIMEOUT_MS;
        for (String id : ids) {
            long remaining = Math.max(0, deadline - time.milliseconds());
            awaitStopConnector(id, remaining);
        }
    }
Stop a connector managed by this worker.

@param connName the connector name.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java