Re: Kafka Cluster Issue

2015-05-03 Thread Kamal C
Any comments on this issue? On Sat, May 2, 2015 at 9:16 AM, Kamal C kamaltar...@gmail.com wrote: Hi, We are using Kafka_2.10-0.8.2.0, new Kafka producer and Kafka Simple Consumer. In Standalone mode, 1 ZooKeeper and 1 Kafka we haven't faced any problems. In cluster mode, 3 ZooKeeper and 3

Re: Kafka Cluster Issue

2015-05-03 Thread Kamal C
We are running ZooKeeper in ensemble (Cluster of 3 / 5). With further investigation, I found that the Connect Exception throws for all inflight producers. Say we are pushing 50 msg/s to a topic. Stop the leader Kafka for that topic. Producers are unable to push messages to the Kafka Cluster and

Re: Delete topic / Recreate = No leader

2015-05-03 Thread 马哲超
I've came accross the same issue with kafka 0.8.10. 2015-05-01 2:51 GMT+08:00 Dillian Murphey crackshotm...@gmail.com: I am trying to reproduce this. But if I create a topic, then delete it, then re-create it, no leader is getting assigned. I can still produce/consume messages (via command

RE: Delete topic / Recreate = No leader

2015-05-03 Thread Aditya Auradkar
I believe there were some issues with delete topic in 0.8.10 (other correct me if I am wrong). Can you try with the most recent release ? Thanks, Aditya From: 马哲超 [mazhechaomaill...@gmail.com] Sent: Sunday, May 03, 2015 7:51 PM To: users@kafka.apache.org

Re: Kafka brokers behind AWS ELB

2015-05-03 Thread Jiangjie Qin
Yes. On 5/3/15, 10:57 AM, Chandrashekhar Kotekar shekhar.kote...@gmail.com wrote: Thanks a lot for the information. So basically each broker needs to have his own public IP address? Regards, Chandrash3khar Kotekar Mobile - +91 8600011455 On Sun, May 3, 2015 at 11:09 PM, Jiangjie Qin

Re: Kafka brokers behind AWS ELB

2015-05-03 Thread Chandrashekhar Kotekar
Thanks a lot for the information. So basically each broker needs to have his own public IP address? Regards, Chandrash3khar Kotekar Mobile - +91 8600011455 On Sun, May 3, 2015 at 11:09 PM, Jiangjie Qin j...@linkedin.com.invalid wrote: You can use ELB address as metadata broker list. But you