如果我理解正确,偏移量会提交给相关主题的偏移量管理器(broker),我假设会发送给动物园管理员,但例如,我有一个复制因子为1的主题,而作为偏移量管理者的broker失败了。由于我没有复制服务器,我会丢失已提交的偏移量吗?如果我的动物园管理员服务器出现故障,我会不会只丢失偏移量。
如果不是,Zookeeper/broker 如何存储服务器故障后要恢复的偏移量,在什么情况下(如果有的话)我会丢失偏移量?
如果我对Kafka/动物园管理员的内部表示不正确,请告诉我。谢谢!
在kafka 0.9.0中,消费者的偏移量是kafka中主题中的商店,并像其他主题一样复制。