企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
# kafka 和 zookeeper 关系 有多个服务器的分布式系统,每台服务器都负责保存数据,在数据上执行操作。这样的潜在例子包括分布式搜索引擎、分布式构建系统或者已知的系统如 Apache Hadoop。所有这些分布式系统的一个常见问题是,你如何在任一时间点确定哪些服务器活着并且在工作中。最重要的是,当面对这些分布式计算的难题,例如网络失败、带宽限制、可变延迟连接、安全问题以及任何网络环境,甚至跨多个数据中心时可能发生的错误时,你如何可靠地做这些事。这些正是 Apache ZooKeeper 所关注的问题,它是一个快速、高可用、容错、分布式的协调服务。你可以使用 ZooKeeper 构建可靠的、分布式的数据结构,用于群组成员、领导人选举、协同工作流和配置服务,以及广义的分布式数据结构如锁、队列、屏障(Barrier)和锁存器(Latch)。许多知名且成功的项目依赖于 ZooKeeper,其中包括 HBase、 Hadoop 2.0、Solr Cloud、 Neo4J、 Apache Blur(Incubating)和 Accumulo。 ZooKeeper 是一个分布式的、分层级的文件系统,能促进客户端间的松耦合,并提供最终一致的,类似于传统文件系统中文件和目录的 Znode 视图。它提供了基本的操作,例如创建、删除和检查 Znode 是否存在。它提供了事件驱动模型,客户端能观察特定 Znode 的变化,例如现有 Znode 增加了一个新的子节点。 ZooKeeper 运行多个 ZooKeeper服务器,称为 Ensemble,以获得高可用性。每个服务器都持有分布式文件系统的内存复本,为客户端的读取请求提供 服务。 7.5) kafka and zookeeper 启动 运行 kafka 需要使用 Zookeeper,所以你需要先启动 Zookeeper,如果你没有 Zookeeper,你可以使用 kafka 自 带打包和配置好的 Zookeeper。 a、启动服务 ``` [root@web bin\]# ./zookeeper-server-start.sh ../config/zookeeper.properties & [root@web bin\]# ./kafka-server-start.sh ../config/server.properties & ``` 29 b、验证启动 ``` [root@web bin\]# jobs [1]- 运行中 ./zookeeper-server-start.sh ../config/zookeeper.properties & [2]+ 运行中 ./kafka-server-start.sh ../config/server.properties & ``` c、关闭服务 ``` [root@web bin\]# ./kafka-server-stop.sh [root@web bin\]# ./zookeeper-server-stop ```