Kafka 0.9:消费者抵消向量的持久性和持久性

Kafka 0.9: Durability and persistance of consumer offset vectors

如果我理解正确,偏移量将提交给相关主题的偏移量管理器(代理),并且我假设已发送给动物园管理员,但是,例如,我有一个具有复制因子的主题1 和经纪人,谁是抵消经理失败。因为我没有复制服务器,我会丢失提交的偏移量吗?如果我的 zookeeper 服务器发生故障,我是否只会丢失偏移量?

如果不是,zookeeper/broker如何存储服务器故障后要恢复的偏移量,在什么情况下,如果有的话,我会丢失偏移量吗?

如果我对 kafka/zookeeper 的内部结构表示不正确,请告诉我。谢谢!

在 kafka 0.9.0 中,消费者的偏移量存储在 kafka 的一个主题中,并像其他主题一样被复制。