void startAndStop(Collection<Callable<Void>> callables, String stageDescription) {
        if (callables.isEmpty())
            return;

        try (TickThreadStage stage = new TickThreadStage(stageDescription)) {
            startAndStopExecutor.invokeAll(callables);
        } catch (InterruptedException e) {
            // ignore
        } catch (RejectedExecutionException e) {
            // Shutting down. Just log the exception
            if (stopping.get()) {
                log.debug("Ignoring RejectedExecutionException thrown while starting/stopping connectors/tasks en masse " +
                        "as the herder is already in the process of shutting down. This is not indicative of a problem and is normal behavior");
            } else {
                throw e;
            }
        }
    }
Try to read to the end of the config log within the given timeout and capture a fresh snapshot via
{@link ConfigBackingStore#snapshot()}

@param timeoutMs maximum time to wait to sync to the end of the log
@return true if successful; false if timed out
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java