There is a JIRA open that should address this: https://issues.apache.org/jira/browse/KAFKA-3853 Since it requires a change in the protocol, it's awaiting a KIP vote that's happening next week ( https://cwiki.apache.org/pages/viewpage.action?pageId=66849788). Once the vote is passed the code should go in fairly quickly.
--Vahid From: Jon Yeargers <jon.yearg...@cedexis.com> To: users@kafka.apache.org Date: 12/02/2016 04:40 AM Subject: Writing a consumer offset checker 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.
