If I understand KAFKA-1476 it is only a command line tool that gives access by using ZKUtils not an API to Kafka. We're looking for a Kafka API so I guess that this functionality is missing.
thanks for the pointer Svante Karlsson 2014-12-12 19:03 GMT+01:00 Jiangjie Qin <j...@linkedin.com.invalid>: > > 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 > >> > >
