@BeforeClass
	public static void initZooKeeper() {
		embeddedZooKeeper.start();
		zkConnection = new ZooKeeperConnection("localhost:"
				+ embeddedZooKeeper.getClientPort());
		zkConnection.start();
	}
Unit tests for {@link ZooKeeperStreamDefinitionRepository}.

@author Eric Bottard
@author David Turanski
@author Gary Russell
@author Mark Fisher
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/zookeeper/ZooKeeperStreamDefinitionRepositoryTests.java