控制器组件（Controller），是 Apache Kafka 核心组件。它的主要功能是 Apache ZooKeeper 在管理和协调整体的帮助下 Kafka 集群。任何一个集群 Broker 它可以作为控制器，但在运行过程中只能有一个 Broker 成为控制器，行使其管理和协调的职责。换句话说，每一次正常运行 Kafka 集群在任何时候都有，只有一个控制器。官网上有个名字 activeController 的 JMX 该指标可以帮助我们实时监控控制器的生存状态。这个 JMX 指标非常关键，你在实际运维操作过程中，一定要实时查看这个指标的值。下面，我们将详细介绍控制器的原理和内部操作机制。 在开始之前，让我简单介绍一下 Apache ZooKeeper 框架。要知道，控制器是严重依赖的 ZooKeeper 因此，有必要花一些时间学习 ZooKeeper 做什么？Apache ZooKeeper 提供高可靠性的分布式协调服务框架。它使用的数据模型类似于文件系统的树形结构，根目录从/开始。该结构上的每个节点都被称为 znode，用于保存元数据协调信息。如果以 znode 持久性划分，znode 可分为持久性 znode 和临时 znode。持久性 znode 不会因为 ZooKeeper 集群重启并暂时消失 znode 则与创建该 znode 的 ZooKeeper 会话绑定，一旦会话结束，节点将自动删除。 ZooKeeper 赋予客户端监控 znode 变更能力，即所谓的 Watch 通知功能。一旦 znode 创建和删除节点，改变子节点的数量，或者 znode 数据本身的变化，ZooKeeper 监视器通过节点变更 (ChangeHandler) 显式通知客户的方式