Hi, Have notice an issue. We retrieve the "kafka.log":type="Log",name="<topic>-<partition>-LogEndOffset" 's Attribute: Value and used it to calculate the lag from consumer's offset. After we did a partition re-assignment, where partition leaders were changed, some of the new leader's LogEndOffset were not updated and the value remain constant. Other utilities tools like the GetOffsetShell and ConsumerOffsetChecker were giving updated LogEndOffsets. So it's just the JMX stopped updating.
Can we confirm that this is an issue and Is there a fix? We are using the 0.8.1.1 and scala 2.10.1 Thanks
