protected void stopWorker(WorkerHandle worker) {
        try {
            log.info("Stopping worker {}", worker);
            worker.stop();
        } catch (UngracefulShutdownException e) {
            log.warn("Worker {} did not shutdown gracefully", worker);
        } catch (Exception e) {
            log.error("Could not stop connect", e);
            throw new RuntimeException("Could not stop worker", e);
        }
    }
Stop the Connect cluster and the embedded Kafka KRaft cluster.
Clean up any temp directories created locally.

@throws RuntimeException if Kafka brokers fail to stop
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java