Partition（分区）是 Kafka 中消息的物理存储单元。每个 Topic 可以被划分为多个 Partition，每个 Partition 是一个有序的、不可变的消息序列，并以日志文件的形式存储在磁盘上。fill:#333;important;important;fill:none;color:#333;color:#333;important;fill:none;fill:#333;hei

Apache Kafka 是一个开源的分布式事件流平台，由 LinkedIn 公司于 2011 年开发，随后捐赠给 Apache 软件基金会并成为顶级开源项目。它最初被设计用于处理 LinkedIn 内部海量的实时数据流，如今已发展成为业界最广泛使用的事件流平台，超过 80% 的"财富 500 强"企业都在使用 Kafka。发布与订阅：应用程序可以发布（写入）事件流，也可以订阅（读取）事件流持久化

Apache Curator 是 Netflix 开源的一款 ZooKeeper 客户端框架，目前已成为 Apache 顶级项目。它是对 ZooKeeper 原生 API 的高层封装，旨在解决 ZooKeeper 使用中的各种痛点，提供更简单、更可靠的编程模型。fill:#333;important;important;fill:none;color:#333;color:#333;importa

网络分区（Network Partition），又称脑裂（Split-Brain），是指分布式系统中因网络故障导致节点间的通信中断，集群分裂成两个或多个独立的部分，每个部分都无法感知其他部分的存在。fill:#333;important;important;fill:none;color:#333;color:#333;important;fill:none;fill:#333;height:1e

高可用性（High Availability，HA）指系统在面对部分组件故障时，仍能持续对外提供服务的能力。维度要求ZooKeeper 的表现无单点故障任何单节点故障不影响整体服务Leader 故障自动选举，Follower 故障无缝转移快速恢复故障后能快速恢复正常服务Leader 选举通常在秒级完成数据不丢失已提交事务必须持久化事务日志 + 数据快照保障自动切换故障转移无需人工干预客户端自动重连

CAP 理论是分布式系统设计中最基础也是最重要的理论之一，由 Eric Brewer 在 2000 年提出。它指出，分布式系统在一致性（Consistency）、**可用性（Availability）和分区容错性（Partition tolerance）**这三个特性中，最多只能同时满足两个，无法三者兼顾。fill:#333;important;important;fill:none;color:

注意事项问题解决方案一次性触发Watcher只触发一次在process()中重新注册轻量级通知事件不包含数据收到通知后主动拉取数据线程模型阻塞EventThread使用独立线程池处理业务逻辑连接状态忽略会话过期监听KeeperState事件Watcher数量注册过多Watcher使用父节点监听代替事件顺序可能延迟但不会乱序依赖ZXID保证顺序权限问题权限不足导致注册失败先添加认证信息永远在proc

ZooKeeper是一个开源的分布式协调服务，它为分布式应用程序提供高效的协调能力。正如其名，ZooKeeper就像是动物园的管理员，负责协调和管理分布式系统中的各种服务。fill:#333;important;important;fill:none;color:#333;color:#333;important;fill:none;fill:#333;height:1em;ZooKeeper的定

ZNode（ZooKeeper Node）是ZooKeeper中数据模型的基本单元，类似于文件系统中的文件或目录。ZooKeeper使用一种树形结构的命名空间来组织这些ZNode。fill:#333;important;important;fill:none;color:#333;color:#333;important;fill:none;fill:#333;height:1em;/ (根节点)

ZooKeeper的数据模型是一个层次化的命名空间，结构上非常类似于标准的文件系统。fill:#333;important;important;fill:none;color:#333;color:#333;important;fill:none;fill:#333;height:1em;/ (根节点)/app1/app2/zookeeper逻辑模型：树形结构的ZNode，类似文件系统，每个节点可