@Override
    public void connectorOffsets(String connName, Callback<ConnectorOffsets> cb) {
        ClusterConfigState configSnapshot = configBackingStore.snapshot();
        try {
            if (!configSnapshot.contains(connName)) {
                cb.onCompletion(new NotFoundException("Connector " + connName + " not found"), null);
                return;
            }
            // The worker asynchronously processes the request and completes the passed callback when done
            worker.connectorOffsets(connName, configSnapshot.connectorConfig(connName), cb);
        } catch (Throwable t) {
            cb.onCompletion(t, null);
        }
    }
Checks a given {@link ConfigInfos} for validation error messages and adds an exception
to the given {@link Callback} if any were found.

@param configInfos configInfos to read Errors from
@param callback callback to add config error exception to
@return true if errors were found in the config
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java