public void requestTimeout(long requestTimeoutMs) {
        workers().forEach(worker -> worker.requestTimeout(requestTimeoutMs));
    }
Set a new timeout for REST requests to each worker in the cluster. Useful if a request
is expected to block, since the time spent awaiting that request can be reduced
and test runtime bloat can be avoided.
@param requestTimeoutMs the new timeout in milliseconds; must be positive
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java