Thank you Hans and Vahid. That was definitely of great help. Much appreciated!
Regards, Jerry On Tue, May 30, 2017 at 1:53 PM, Vahid S Hashemian < vahidhashem...@us.ibm.com> wrote: > Hi Jerry, > > The behavior you are expecting is implemented in 0.10.2 through KIP-88 ( > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 88%3A+OffsetFetch+Protocol+Update > ) and KAFKA-3853 (https://issues.apache.org/jira/browse/KAFKA-3853). > Starting from this release when you query a consumer group (new consumer > only) you'll see the stored offset corresponding to a topic partition even > if there is no active consumer consuming from it. > > I hope this helps. > --Vahid > > > > > From: Jerry George <jerr...@gmail.com> > To: users@kafka.apache.org > Date: 05/26/2017 06:55 AM > Subject: Trouble with querying offsets when using new consumer > groups API > > > > Hi > > I had question about the new consumer APIs. > > I am having trouble retrieving the offsets once the consumers are > *disconnected* when using new consumer v2 API. Following is what I am > trying to do, > > *bin/kafka-consumer-groups.sh -new-consumer --bootstrap-server kafka:9092 > --group group --describe* > > If I query this when the consumers are connected, there is no problem. > However, once the consumers are disconnected it says there is no such > group, though the offsets are retained in __consumer_offsets. > > The offset retention policy is default; i.e. 1440 minutes, I believe. > > Once the consumers are reconnected, I am able to query the offsets once > again. > > Could anyone here please help me understand why this is? > > Kafka: 0.10.1 > Consumer Library: sarama golang library > > Regards, > Jerry > > > > >
