最近做了一个试验(Kafka version 1.0.0)。当ZooKeeper当机后,数据仍然还能自如向Kafka内发生数据和消费数据。当单个节点当机后,就不再存在备份Leader切换的策略了。有熟悉源码的大佬给点指点么,据说Kafka从1.0.0版本后数据的offeset存储在Kafka端了,而不是以前依赖的ZooKeeper了。
zookeeper充当了kafka集群之间互相发现的角色。所以当zookeeper失效后,集群之间不会再发现新的节点,会维护内部已发现的一套节点列表。另外因为生产者和消费者已经与kafka建立了连接,并也有了一份节点列表,所以还可继续发送和消费。
你的答案