public boolean allWorkersHealthy() {
        return workers().stream().allMatch(this::isHealthy);
    }
Determine whether the Connect cluster has all workers running.

@return true if all workers are running, or false otherwise
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java