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

Reply via email to