public void removeWorker(WorkerHandle worker) {
        if (connectCluster.isEmpty()) {
            throw new IllegalStateException("Cannot remove worker. Cluster is empty");
        }
        stopWorker(worker);
        connectCluster.remove(worker);
    }
Decommission a specific worker from this Connect cluster.

@param worker the handle of the worker to remove from the cluster
@throws IllegalStateException if the Connect cluster has no workers
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java