Hi Jon We have written an offset check in python for the new consumer groups.
I've filed a bug against pykafka with some admin command support here https://github.com/Parsely/pykafka/issues/620#issuecomment-264258141 That you could use right now If not I should be able to release an offset checker by next weekend that you could use We have consumer lag monitoring integrated to sysdig cloud this way Regards Toby Sent from my iPhone > On 2 Dec 2016, at 8:39 PM, Jon Yeargers <jon.yearg...@cedexis.com> wrote: > > I want to write my own offset monitor so I can integrate it with our > alerting system. I've tried Java and Java + Scala but have run into the > same problem both times. (details here: > http://stackoverflow.com/questions/40808678/kafka-api-offsetrequest-unable-to-retrieve-results > ) > > If anyone has a working Java solution for 'new-consumer' groups I'd love to > hear about it.
