Hi Siddharth,
The way i do it is,
stormConf.put("storm.zookeeper.servers", "<zk ips>");
stormConf.put("storm.zookeeper.port", "<zk port>"); // that would be 2181
in your case.
_cluster = new LocalCluster();
_cluster.submitTopology(name, stormConf, topology);
And that way i m able to get storm connect to an external zk.
Regards,
Samit
On Mon, Sep 15, 2014 at 7:12 PM, siddharth ubale <[email protected]>
wrote:
> Hi ,
>
> Is there anyway we can connect to the zookeeper at 2181 rather than
> Storm's in memory zookeeper at 2000?
> I am trying to get kafka spout write its partitions in the zookeeper via
> storm topology but i am unable to do so since Storm is using the default
> zookeeper at 2000.
> using 0.9.2-incubating ...
>
> Thanks,
> Siddharth
>
