Hi All, I am comparing the output from kafka.tools.ConsumerOffsetChecker vs JMX (kafka.server:type=FetcherLagMetrics,name=ConsumerLag,clientId=logstash,topic=logstash_fdm,partition=*) and they do not match.
ConsumerOffsetChecker is showing ~60 Lag per partition and JMX shows 0 for all partitions. I am running kafka_2.11-0.8.2.2 and using jconsole to connect to JMX. Has anyone seen this issue before? I am trying to use JMX to pull stats into monitoring system -- Allen Michael Chan