Hi Gaspar, Your brokerZkStr should contain the comma-separated string of zookeper host:port,e.g brokerZkStr = "abc.com:2181,xyz.com:2182"
Thanks Bijoy On Wed, Feb 5, 2014 at 9:53 PM, Gaspar Muñoz < [email protected]> wrote: > Hi, I use KafkaSpout and I've been testing a topology in local mode and a > distributed enviroment with 1 Kafka machine and 1 storm machine. > > Now, I am going to try in a distributed enviroment with a couple of Kafka > + Zookeeper machines and another 3 Storm. > > My doubt is, in zkHosts, what brokerZkStr should I use if I have a > Zookeeper cluster (2 machines)? > > public ZkHosts(String brokerZkStr, String brokerZkPath) { > this.brokerZkStr = brokerZkStr; > this.brokerZkPath = brokerZkPath; > } > > Thank you. >
