Hi, I was wondering if there's an easy way to get the current offset of a specified consumer? What we need is something to check the consumer offset every 5 min. If it's changing at a certain rate every time we check, good. If not, then we have a problem. I was going to write a monitoring program to check the broker or consumer for this offset to see if it changed and how much it changed since the last time I checked it.
I ran into this pg on the wiki which looks like it's what I need. https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit%2FFetchAPI However, it says the API calls are not functional yet. Are there some other methods or APIs or JMX bean/object/etc that we can use in the meantime? If I were to ping zookeeper, where do I look for this offset? Thanks in advance for your help.
