Re: Storm Kafka offset monitoring

2017-02-24 Thread Ambud Sharma
od to use. However, we should use the >> newer spout. The one that is uses broker hosts. Reason is it uses latest >> kafka consumer api. When do you get commit failed exception? Can you send >> your worker logs where the spout is running? If you don’t see anything In >> the logs try c

Re: Storm Kafka offset monitoring

2017-02-21 Thread pradeep s
torm.apache.org> > *Date: *Tuesday, February 21, 2017 at 12:49 PM > *To: *"user@storm.apache.org" <user@storm.apache.org> > *Subject: *Re: Storm Kafka offset monitoring > > > > Hi Priyank > > Thanks for your reply.i was not able to find 1.1.0 version of storm >

Re: Storm Kafka offset monitoring

2017-02-21 Thread Priyank Shah
9:44 AM To: "user@storm.apache.org<mailto:user@storm.apache.org>" <user@storm.apache.org<mailto:user@storm.apache.org>> Subject: Storm Kafka offset monitoring Hi , I am using Storm 1.0.2 and Kafka 0.10.1.1 versions . Storm spout is configured using zookeeper broker hosts. Is t

Re: Storm Kafka offset monitoring

2017-02-21 Thread pradeep s
m: *pradeep s <sreekumar.prad...@gmail.com> > *Reply-To: *"user@storm.apache.org" <user@storm.apache.org> > *Date: *Tuesday, February 21, 2017 at 9:44 AM > *To: *"user@storm.apache.org" <user@storm.apache.org> > *Subject: *Storm Kafka offset

Re: Storm Kafka offset monitoring

2017-02-21 Thread Priyank Shah
rad...@gmail.com> Reply-To: "user@storm.apache.org" <user@storm.apache.org> Date: Tuesday, February 21, 2017 at 9:44 AM To: "user@storm.apache.org" <user@storm.apache.org> Subject: Storm Kafka offset monitoring Hi , I am using Storm 1.0.2 and Kafka 0.10.1.1 versions . Stor

Storm Kafka offset monitoring

2017-02-21 Thread pradeep s
Hi , I am using Storm 1.0.2 and Kafka 0.10.1.1 versions . Storm spout is configured using zookeeper broker hosts. Is there a monitoring ui which i can use to track the consumer offsets and lag. I was using yahoo kafka manager , but its showing storm spout as a consumer.Any help? Regards Pradeep S