多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
:-: ![](https://img.kancloud.cn/c9/ea/c9eabfd456ef6e2c9d38c5d72e22b0a9_974x649.png) ZooKeeper在Kafka中的作用 * Broker注册并监控状态 * znode:/brokers/ids,保存了所有 Broker id,实现对 Broker 的动态监控。 * Topic注册 * znode:/brokers/topics,保存了所有 Topic。 * 生产者负载均衡 * 每个Broker启动时,都会完成Broker注册过程,生产者会通过该节点的变化来动态地感知到Broker服务器列表的变更 * offset维护 * Kafka早期版本使用ZooKeeper为每个消费者存储offset,由于ZooKeeper写入性能较差,从0.10版本后,Kafka使用自己的内部主题维护offset