use external zookeeper in storm 0.9.2

[applyhhj <ap...@163.com>]

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