private void scheduleReload(String connectorName, String path, long ttl) {
        Map<String, HerderRequest> connectorRequests = requests.computeIfAbsent(connectorName, s -> new ConcurrentHashMap<>());
        connectorRequests.compute(path, (s, previousRequest) -> {
            if (previousRequest != null) {
                // Delete previous request for ttl which is now stale
                previousRequest.cancel();
            }
            log.info("Scheduling a restart of connector {} in {} ms", connectorName, ttl);
            Callback<Void> cb = (error, result) -> {
                if (error != null) {
                    log.error("Unexpected error during connector restart: ", error);
                }
            };
            return worker.herder().restartConnector(ttl, connectorName, cb);
        });
    }
A wrapper class to perform configuration transformations and schedule reloads for any
retrieved TTL values.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java