kafka学习九-消费者offset存储

kafka在0.9版本之前,消费者offset存储在zk中,路径是 /consumers/[groupId]/offsets/[topic]/[partition]

kafka学习九-消费者offset存储

0.9版本之后将offset放在kafka内置的一个topic中,该topic是__consumer_offsets,消费该topic需要修改consumer.properties文件
exclude.internal.topics=false
也是根据[groupId,topic,partition]来划分的

kafka学习九-消费者offset存储