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 j

Re: Problem determining consumer lag via jmx

2014-10-03 Thread Jun Rao
The jmx is only available in the high level consumer. If you are using SimpleConsumer, you have to calculate this yourself (hw from fetchresponse - fetch offset). Thanks, Jun On Fri, Oct 3, 2014 at 5:32 AM, Devang Shah wrote: > Refering to the monitoring secton available on the kafka doc websi