Mailing-List: contact user-help@storm.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@storm.incubator.apache.org
Received-SPF: pass (nike.apache.org: domain of bijoy.computers@gmail.com
 designates 209.85.216.52 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAAQYQqPxhFduTXe183YEJj6_2bvee63RbNP63+=egX2hnbPCMw@mail.gmail.com>
References: 
 <CAAQYQqPxhFduTXe183YEJj6_2bvee63RbNP63+=egX2hnbPCMw@mail.gmail.com>
Date: Wed, 5 Feb 2014 23:00:54 +0530
Message-ID: 
 <CAGBoazhTpZWJB6YaLqLJ1sXGOoe+19CrokbstTs2YWjZEoL8YA@mail.gmail.com>
Subject: Re: ZkHosts KafkaSpout
From: bijoy deb <bijoy.computers@gmail.com>
To: user@storm.incubator.apache.org
Content-Type: multipart/alternative; boundary=089e0160a3d07cdeb804f1ac1e72

--089e0160a3d07cdeb804f1ac1e72
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

Hi Gaspar,

Your brokerZkStr should contain the comma-separated string of zookeper
host:port,e.g
brokerZkStr =3D "abc.com:2181,xyz.com:2182"

Thanks
Bijoy


On Wed, Feb 5, 2014 at 9:53 PM, Gaspar Mu=F1oz <
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 =3D brokerZkStr;
>     this.brokerZkPath =3D brokerZkPath;
>   }
>
> Thank you.
>

--089e0160a3d07cdeb804f1ac1e72
Content-Type: text/html; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div><div>Hi Gaspar,<br><br></div>Your brokerZkStr sh=
ould contain the comma-separated string of zookeper host:port,e.g <br>broke=
rZkStr =3D &quot;<a href=3D"http://abc.com:2181">abc.com:2181</a>,<a href=
=3D"http://xyz.com:2182">xyz.com:2182</a>&quot;<br>
<br></div>Thanks<br></div>Bijoy<br></div><div class=3D"gmail_extra"><br><br=
><div class=3D"gmail_quote">On Wed, Feb 5, 2014 at 9:53 PM, Gaspar Mu=F1oz =
<span dir=3D"ltr">&lt;<a href=3D"mailto:gmunoz@paradigmatecnologico.com" ta=
rget=3D"_blank">gmunoz@paradigmatecnologico.com</a>&gt;</span> wrote:<br>
<blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1p=
x #ccc solid;padding-left:1ex"><div dir=3D"ltr">Hi, I use KafkaSpout and I&=
#39;ve been testing a topology in local mode and a distributed enviroment w=
ith 1 Kafka machine and 1 storm machine.=A0<div>
<br></div><div>Now, I am going to try in a distributed enviroment with a co=
uple of Kafka + Zookeeper machines and another 3 Storm.=A0</div>
<div><br></div><div>My doubt is, =A0in zkHosts, what brokerZkStr should I u=
se if I have a Zookeeper cluster (2 machines)?</div><div><br></div><div><di=
v>=A0public ZkHosts(String brokerZkStr, String brokerZkPath) {</div><div>=
=A0 =A0 this.brokerZkStr =3D brokerZkStr;</div>

<div>=A0 =A0 this.brokerZkPath =3D brokerZkPath;</div><div>=A0 }</div></div=
><div><br></div><div>Thank you.</div></div>
</blockquote></div><br></div>

--089e0160a3d07cdeb804f1ac1e72--