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.
>
|