public void stopAndAwaitConnectors() {
        stopAndAwaitConnectors(new ArrayList<>(connectors.keySet()));
    }
Stop asynchronously all the worker's connectors and await their termination.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java