kafka在0.9版本之前，消费者offset存储在zk中，路径是 /consumers/[groupId]/offsets/[topic]/[partition]
0.9版本之后将offset放在kafka内置的一个topic中，该topic是__consumer_offsets，消费该topic需要修改consumer.properties文件
exclude.internal.topics=false
也是根据[groupId,topic,partition]来划分的
相关文章：
相似解决方案
热门标签