文章目录
  1. 1. 1. At a High level
  2. 2. 2. One level deeper
  3. 3. 3. Now how Kafka uses ZooKeeper?

本文翻译自Quora一则提问, 原文链接: https://www.quora.com/What-is-the-actual-role-of-ZooKeeper-in-Kafka

要理解Kafka内部是如何使用ZooKeeper,我们首先要了解ZooKeeper。下面我将尝试直观的解释ZooKeeper如何工作。我将尽我所能,避免使用技术用语,并保持简单。

1. At a High level

首先,ZooKeeper肯定是一个客户端可以连接到的服务。它提供了一个树状结构(ZooKeeper文档称之为分层命名空间),以便客户端访问。那么,我们为什么需要这棵树?当然是为了存储数据,因此这棵树被称作”data tree”. 在这棵树上,你可以做整套CRUD操作。它采用标准UNIX文件路径表示法。例如,我们使用 /A/B/C 表示C这个zNode节点的路径,其中B是C的父节点,而同理A是B的父节点。
下面是一个例子:

这看起来很像一个UNIX文件系统对吧?下面是若干定义

  1. 每个节点称为zNode
  2. 每个zNode在树中由PATH标示
  3. zNode有两种类型 –persistent(持久节点)ephemeral(临时节点)
  4. 每个zNode里可以存储值数据,zNode可以有子节点
  5. zNodes一旦创建不可以重命名
  6. 可以在zNode上添加/删除WATCH

有人说ZooKeeper的API过于基础,应当基于它做一些Recipes封装。可以看一下由Netflix编写的Curator框架(目前已贡献给Apache),Curator替我们解决了很多问题。

另外,WATCH是一个很有趣的组件,你可以为某个zNode添加WATCH,当某些事件发生的时候会得到通知。比如它可以订阅某个路径上数据的变更。

注: Recipe 词典的意思是食谱,配方,美食菜谱,烹饪法, 延伸用法:某项计划或步骤来取得预先给定的结果。 在计算机领域没有合适的汉语对应,如果把ZooKeeper看成菜的话,recipe就相当于菜谱, 比如麻婆豆腐, 宫保鸡丁。个人认为Recipes在这里指Leader选举、分布式锁、分布式事物等ZooKeeper常见用途的封装。

2. One level deeper

让我们看一下另一个例子,它的目的是基于键值对格式将若干配置信息保存起来,并在整个集群中可用。这些键值对应该持久化于磁盘,并且应该保证高可用、冗余和容错。而ZooKeeper正是为此而生。

如果想尝试一番,现在可以将ZooKeeper安装到本地,进入其bin目录,运行如下命令:

zkCli.sh –server 127.0.0.1:2181

你可以看到一些提示信息,最后如下:

[zk: 127.0.0.1:2181(CONNECTED) 1]

继续尝试如下命令:

一旦zNode被创建,你可以使用GET或SET操作,将其当做分布式KV存储或hashmap来使用。
你也可以安装netflix exhibitor,它是一个基于UI的ZooKeeper管理面板,可以使用它可视化观察ZooKeeper中的数据。

3. Now how Kafka uses ZooKeeper?

Kafka于v0.8版本使用ZooKeeper保存各种配置数据,并以分布式方式在整个集群中访问。观察如下两个简单用例中,Kafka如何将数组组织于ZooKeeper

  1. Topics under a broker -/brokers/topics/[topic]
  2. Next Offset for a Consumer/Topic/Partition combination - /consumers/[groupId]/offsets/[topic]/[partitionId]

文章目录
  1. 1. 1. At a High level
  2. 2. 2. One level deeper
  3. 3. 3. Now how Kafka uses ZooKeeper?