You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Squarek Code <sq...@gmail.com> on 2015/06/11 05:44:08 UTC

offset storage as kafka

Apologies for my novice question:

I changed the offset storage to kafka (0.8.2.1) using the consumer property
offsets.storage=kafka. I see that a new topic, __consumer_offsets got
created.
But after this I could still see the consumer group offset changing in
zookeeper.

The config consumer.properties now contains:

offsets.storage=kafka
dual.commit.enabled=false
exclude.internal.topics=false

Did I miss some configuration? Is there a way to view __consumer_offsets?

Thanks
Kris