What's your use case for knowing all consumer groups? For admin? Yes, I need to monitor producer and consumer lags from several interconnected kafka sites.
/svante 2014-12-16 0:34 GMT+01:00 Jun Rao <j...@confluent.io>: > > What's your use case for knowing all consumer groups? For admin? > > Thanks, > > Jun > > On Fri, Dec 12, 2014 at 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 > > > > > >
