public EmbeddedKafkaCluster kafka() {
        return kafkaCluster;
    }
Return the handle to the Kafka cluster this Connect cluster connects to.

@return the Kafka cluster handle
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java