Problem determining consumer lag via jmx

2014-10-03 Thread Devang Shah
Refering to the monitoring secton available on the kafka doc website I am unable to see kafka.consumer bean on the jconsole. Is this bean not exposed via jconsole ? kafka.consumer:name=([-.\w]+)-MaxLag,type=ConsumerFetcherManager I am using kafka-0.8.1.1. Also when I try to connect via a java

Re: Kafka consumer - Mbean for max lag

2014-10-03 Thread Shah, Devang1
Hi, Referring to http://kafka.apache.org/documentation.html#java Number of messages the consumer lags behind the producer by kafka.consumer:name=([-.\w]+)-MaxLag,type=ConsumerFetcherManager I could not find MBean kafka.consumer when I hooked up jconsole to kafka server. I am using

Re: Kafka consumer - Mbean for max lag

2014-10-03 Thread ravi singh
The MaxLag mbean is only valid for an active consumer. So while the consumer is actively running, it should be accurate. On Fri, Oct 3, 2014 at 4:21 AM, Shah, Devang1 devang1.s...@citi.com wrote: Hi, Referring to http://kafka.apache.org/documentation.html#java Number of messages the