@Override
        public void run() {
            try {
                if (!startLatch.await(SHUTDOWN_TIMEOUT_SECONDS, TimeUnit.SECONDS)) {
                    log.error("Timed out in shutdown hook waiting for MirrorMaker startup to finish. Unable to shutdown cleanly.");
                }
            } catch (InterruptedException e) {
                log.error("Interrupted in shutdown hook while waiting for MirrorMaker startup to finish. Unable to shutdown cleanly.");
            } finally {
                MirrorMaker.this.stop();
            }
        }
@param config    MM2 configuration from mm2.properties file
@param clusters  target clusters for this node. These must match cluster
                 aliases as defined in the config. If null or empty list,
                 uses all clusters in the config.
@param time      time source
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java