Thanks a lot Guozhang. Very helpful comment.
best,
/Shahab
On Wed, Feb 19, 2014 at 5:46 PM, Guozhang Wang wangg...@gmail.com wrote:
Group management like load balancing only exists in high level consumers,
SimpleConsumer do not have the group id settings since it does not have
group
Hi,
I am using kafka for the first time, and was running the sample from
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
However, I cannot read any data from kafka. The kafka has 10 partitions,and
I tried to read from any of them. The fetch can succeed, however, the
Never mind. It was actually working. I just need to wait a bit longer for
data to come into the partition i was testing for.
Chen
On Thu, Feb 20, 2014 at 2:41 PM, Chen Wang chen.apache.s...@gmail.comwrote:
i am using 0.8.0. The high level api works as expected.
dependency
All the brokers reside in the same server and are listening on the port
10092,10093,10094. From the same machine I can connect to the zookeeper and the
brokers. But When I tried to connect from an external machine (from Eclipse), I
get an exception as communicated earlier. I was not able to
Have you changed the JMX port when starting?
On Thu, Feb 20, 2014 at 10:37 PM, Balasubramanian Jayaraman (Contingent)
balasubramanian.jayara...@autodesk.com wrote:
All the brokers reside in the same server and are listening on the port
10092,10093,10094. From the same machine I can connect to
That explains why your producer hits connection timeout. Not sure why the
controller to broker connection also times out though, if you can manually
establish the connection.
Thanks,
Jun
On Thu, Feb 20, 2014 at 7:37 PM, Balasubramanian Jayaraman (Contingent)
I haven't enabled the JMX. I disabled the configuration and started the Kafka
brokers.
Thanks
Bala
-Original Message-
From: Joe Stein [mailto:joe.st...@stealth.ly]
Sent: Friday, 21 February, 2014 11:49 AM
To: users@kafka.apache.org
Subject: Re: Reg Exception in Kafka
Have you changed
One point to note is that, I am trying to access the Kafka broker (located in
Amazon Cloud, EC2 instance) from the Eclipse (located in my office). I am using
Kafka from the trunk .
Thanks
Bala
-Original Message-
From: Jun Rao [mailto:jun...@gmail.com]
Sent: Friday, 21 February, 2014
