public String adminEndpoint(String resource) {
        String url = workers().stream()
                .map(WorkerHandle::adminUrl)
                .filter(Objects::nonNull)
                .findFirst()
                .orElseThrow(() -> new ConnectException("Admin endpoint is disabled."))
                .toString();
        return url + resource;
    }
Get the full URL of the admin endpoint that corresponds to the given REST resource

@param resource the resource under the worker's admin endpoint
@return the admin endpoint URL
@throws ConnectException if no admin REST endpoint is available
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java