Hi, Does anybody know how to run topology in local mode with external Zookeeper in Storm 0.9.2-incubating? I tried to configure the port and server but it continues to throw out NullPointerException. Anyone can help? Thank you very much!!
here is the code public static void main(String[] args) throws Exception { List<String> zkServers=new ArrayList<String>(); zkServers.add("127.0.0.1"); Config conf = new Config(); conf.setDebug(false); conf.put(Config.STORM_ZOOKEEPER_SERVERS,zkServers); conf.put(Config.STORM_ZOOKEEPER_PORT,2181); // deploy on a local cluster conf.setMaxTaskParallelism(3); final LocalCluster cluster = new LocalCluster(conf); final BuildMyTopology topology = new BuildMyTopology(cluster, conf, "default"); topology.buildTopology(); topology.submit(); Thread.sleep(1000000); LOG.info("Stopping topology.....................................!!"); cluster.killTopology("default"); cluster.shutdown(); } the error 3476 [main] ERROR org.apache.zookeeper.server.NIOServerCnxnFactory - Thread Thread[main,5,main] died java.lang.NullPointerException: null at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:26) ~[clojure-1.5.1.jar:na] at backtype.storm.testing$submit_local_topology.invoke(testing.clj:253) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.LocalCluster$_submitTopology.invoke(LocalCluster.clj:38) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.LocalCluster.submitTopology(Unknown Source) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at org.SimpleTopology.BuildMyTopology.submit(BuildMyTopology.java:68) ~[classes/:na] at org.SimpleTopology.run.main(run.java:51) ~[classes/:na] 2015-06-18