@Override
    public void connectorOffsets(String connName, Callback<ConnectorOffsets> cb) {
        log.trace("Submitting offset fetch request for connector: {}", connName);
        // Handle this in the tick thread to avoid concurrent calls to the Worker
        addRequest(
                () -> {
                    super.connectorOffsets(connName, cb);
                    return null;
                },
                forwardErrorAndTickThreadStages(cb)
        );
    }
Builds and executes a restart plan for the connector and its tasks from <code>request</code>.
Execution of a plan involves triggering the stop of eligible connector/tasks and then queuing the start for eligible connector/tasks.

@param request the request to restart connector and tasks
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java