Re: Kafka consumer - Mbean for max lag

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

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

Re: Kafka consumer - Mbean for max lag

Thanks Neha, Looks like this mbean was added recently. The version we are running is from early June and it doesn't have this Mbean. Thanks, Raja. On Mon, Sep 23, 2013 at 9:15 PM, Neha Narkhede neha.narkh...@gmail.comwrote: On the consumer side, look for

Re: Kafka consumer - Mbean for max lag

Yes, that is correct. We added this and *MinFetchRate recently. On Tue, Sep 24, 2013 at 9:10 AM, Rajasekar Elango rela...@salesforce.comwrote: Thanks Neha, Looks like this mbean was added recently. The version we are running is from early June and it doesn't have this Mbean. Thanks, Raja.