public String getZkConnectString() {
		return zkServer.getConnectString();
	}
See XD-2293. This is used to reproduce Kafka rebalance issues.
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/kafka/TestKafkaCluster.java