@@ -0,0 +1,719 @@
+package ch.uzh.ddis.katts.utils;%0A%0Aimport java.io.IOException;%0Aimport java.util.List;%0Aimport java.util.Map;%0A%0Aimport org.apache.zookeeper.ZooKeeper;%0A%0Aimport backtype.storm.Config;%0A%0Apublic final class Cluster %7B%0A%09%0A%09%0A%09public static ZooKeeper createZooKeeper(Map conf) throws IOException %7B%0A%09%09%0A%09%09@SuppressWarnings(%22unchecked%22)%0A%09%09List%3CString%3E zooKeeperServers = (List%3CString%3E)conf.get(Config.STORM_ZOOKEEPER_SERVERS);%0A%09%09%0A%09%09Integer port = (Integer)conf.get(Config.STORM_ZOOKEEPER_PORT);%0A%09%09%0A%09%09%0A%09%09StringBuilder connection = new StringBuilder();%0A%09%09%0A%09%09for (String server : zooKeeperServers) %7B%0A%09%09%09connection.append(server).append(%22:%22).append(port).append(%22,%22);%0A%09%09%7D%0A%09%09%0A%09%09return new ZooKeeper(connection.toString(), 3000, null);%0A%09%7D%0A%0A%7D%0A

Add missing Util class for constructing ZooKeeper instances from storm configuration.