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.
