KAFKA-1476 is addressing this need, but it¹s not checked in yet. Currently maybe you can use zookeeper client to check the zookeeper path.
‹Jiangjie (Becket) Qin On 12/12/14, 2:45 AM, "svante karlsson" <s...@csi.se> wrote: >Disregard the creation question - we must have done something wrong >because >now our code is working without obvious changes (on another set of >brokers). > >However it turns out to be difficult to know the existing consumer group >strings. Is the message format in __consumer_offsets "public"/stable in >any >way or is there a better way of listing the existing group names? > >svante > > >2014-12-11 20:59 GMT+01:00 svante karlsson <s...@csi.se>: >> >> We're using 0.82 beta and a homegrown c++ async library based on boost >> asio that has support for the offset api. >> (apikeys OffsetCommitRequest = 8, OffsetFetchRequest = 9, >> ConsumerMetadataRequest = 10) >> >> If we use a java client and commit an offset then the consumer group >>shows >> up in the response from ConsumerMetadataRequest. However I cant figure >>out >> how to create a new one using the Kafka API. >> >> Also, my __consumer_offsets topic shows up with a replication factor of >>1. >> Is that changeable? >> >> thanks, >> svante >>
