Okay, I see.
According to this document, we need to set a consumer id for each groupid
I created a JIRA for fixing this issue:
On Wed, Oct 12, 2016 at 8:08 PM, Anchit Jatana <development.anc...@gmail.com
> Hi Robert,
> Thanks for your response. I just figured out what the issue is.
> The reason why- bin/kafka-consumer-groups.sh --zookeeper
> <zookeeper-url:port> --describe --group <group-id> is not showing any
> is because of the absence of the
> /consumers/<group-id>/owners/<topic> in the zookeeper.
> The flink application is creating and updating
> /consumers/<group-id>/offsets/<topic>/<partition> but not creating
> If I manually create the Znode using the following:
> create /consumers/<group-id>/owners “firstchildren”
> create /consumers/<group-id>/owners/<topic> null
> It works fine, bin/kafka-consumer-groups.sh --zookeeper
> --describe --group <group-id> starts pulling offset results for me.
> I think this needs to be corrected in the application: to check and create
> "/consumers/<group-id>/owners/<topic>" if it does not exist.
> View this message in context: http://apache-flink-user-
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.