Return-Path: X-Original-To: apmail-storm-user-archive@minotaur.apache.org Delivered-To: apmail-storm-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8D3C910828 for ; Wed, 5 Feb 2014 16:23:47 +0000 (UTC) Received: (qmail 96429 invoked by uid 500); 5 Feb 2014 16:23:46 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 96400 invoked by uid 500); 5 Feb 2014 16:23:46 -0000 Mailing-List: contact user-help@storm.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.incubator.apache.org Delivered-To: mailing list user@storm.incubator.apache.org Received: (qmail 96390 invoked by uid 99); 5 Feb 2014 16:23:46 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Feb 2014 16:23:46 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW X-Spam-Check-By: apache.org Received-SPF: unknown ~allipv4:62.82.24.134 (athena.apache.org: encountered unrecognized mechanism during SPF processing of domain of gmunoz@paradigmatecnologico.com) Received: from [74.125.82.169] (HELO mail-we0-f169.google.com) (74.125.82.169) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Feb 2014 16:23:39 +0000 Received: by mail-we0-f169.google.com with SMTP id t61so470915wes.14 for ; Wed, 05 Feb 2014 08:23:18 -0800 (PST) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:date:message-id:subject:from:to :content-type; bh=auV4esa5YlR1wIOPc5TJyTuNVcdEZMK1j5rpjgdrMLc=; b=Z1nprWvEyvhrNfeAebD8LZUHRqCID5i6QpKpk/YaYv4rZMQYUA+aPAj1BmRpb+qwly 5OcD4jUqj8+Gs4J+0mJ+nHvg7vvUSXmGEChdK3F6rM0uT0rp9PypPYfBYwOscWw24Yyh 63HNfnpYPF048FOmyOKDxqZwj81n0oj0reaHSY7AUAtBgLOlFQE/5QYgRyo6xHDE73s7 XPNgBiuc0FafkiuetkEvsAQaIFd2Ei2q5x9LBxx597ApH1U8TC8f1MumOp3cZWnPHNj7 WGE0jlIT4iS5GHf4bdHw5kwlvBTkJZsWXAHLwSWhIPsC/5eupdafchSjFQpq5sArQwDX cKkQ== X-Gm-Message-State: ALoCoQktqbVlSqi7Brr4h5fBvYZnjQ4LxNwNiwhWWYQb8dIS0NFt8clYbHe7sOJ6+O48iL247NzS MIME-Version: 1.0 X-Received: by 10.180.160.206 with SMTP id xm14mr3191183wib.25.1391617398136; Wed, 05 Feb 2014 08:23:18 -0800 (PST) Received: by 10.180.24.7 with HTTP; Wed, 5 Feb 2014 08:23:18 -0800 (PST) X-Originating-IP: [62.82.24.134] Date: Wed, 5 Feb 2014 17:23:18 +0100 Message-ID: Subject: ZkHosts KafkaSpout From: =?ISO-8859-1?Q?Gaspar_Mu=F1oz?= To: user@storm.incubator.apache.org Content-Type: multipart/alternative; boundary=047d7b6225b0adfe9d04f1ab2c3f X-Virus-Checked: Checked by ClamAV on apache.org --047d7b6225b0adfe9d04f1ab2c3f Content-Type: text/plain; charset=ISO-8859-1 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. --047d7b6225b0adfe9d04f1ab2c3f Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
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.=A0

Now, I am going to try in a distributed env= iroment with a couple of Kafka + Zookeeper machines and another 3 Storm.=A0=

My doubt is, =A0in zkHosts, what brokerZkStr should I u= se if I have a Zookeeper cluster (2 machines)?

=A0public ZkHosts(String brokerZkStr, String brokerZkPath) {
= =A0 =A0 this.brokerZkStr =3D brokerZkStr;
=A0 =A0 this.brokerZkPath =3D brokerZkPath;
=A0 }

Thank you.
--047d7b6225b0adfe9d04f1ab2c3f--