编辑“︁Kafka消息系统”︁（章节）

== 核心概念 ==
Kafka的核心架构围绕以下几个关键概念构建：

=== 1. 主题（Topic） ===
主题是消息的分类名称，生产者将消息发布到特定主题，消费者从主题订阅消息。一个Kafka集群可以管理多个主题。

=== 2. 分区（Partition） ===
每个主题可以被分为多个分区，分区是物理存储单位。分区提供：
* 并行处理能力
* 数据冗余（通过副本）
* 消息顺序保证（仅在分区内）

=== 3. 生产者（Producer） ===
生产者是向Kafka主题发布消息的客户端应用程序。生产者决定将消息发送到哪个分区（可通过轮询、键哈希或自定义策略）。

=== 4. 消费者（Consumer） ===
消费者从主题读取消息的客户端应用程序。消费者可以：
* 单独消费（单个消费者）
* 组成消费者组（实现负载均衡）

=== 5. 代理（Broker） ===
Kafka服务器实例，负责消息存储和转发。多个代理组成Kafka集群。

=== 6. ZooKeeper协调 ===
Kafka使用ZooKeeper管理集群元数据、领导者选举和消费者偏移量（新版本已逐步减少对ZooKeeper的依赖）。

<mermaid>
graph TD
    P[Producer] -->|发布消息| T[Topic]
    T -->|分区1| B1[Broker1]
    T -->|分区2| B2[Broker2]
    C1[Consumer1] -->|订阅| T
    C2[Consumer2] -->|订阅| T
    B1 -.-> Z[ZooKeeper]
    B2 -.-> Z
</mermaid>