storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bijoy deb <bijoy.comput...@gmail.com>
Subject Re: ZkHosts KafkaSpout
Date Wed, 05 Feb 2014 17:30:54 GMT
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 <
gmunoz@paradigmatecnologico.com> 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.
>

Mime
View raw message