![]()
- Producer：生产者负责将数据发布到 Kafka 中的主题（Topic）。消息会按照某种逻辑（如轮询、键值哈希等）分发到该主题的不同分区，生产者可以发送单个消息或者批量消息到指定的主题。
- Consumer：消费者从主题中的特定分区读取消息。消费者可以是单个实例，也可以组成一个消费者组（Consumer Group）。Kafka 支持多消费者模型，每个消费者组能够独立读取主题中的数据。Kafka 通过消费者组（Consumer Group）管理消费进度，确保消息被所有需要的消费者组消费。
- Broker：Kafka 集群中的每个节点称为一个 Broker。Broker 负责接收、存储和提供来自生产者的消息。一个 Kafka 集群通常由多个 Broker 组成，每个主题的分区会分布在不同的 Broker 上，分布式存储消息，以实现高可用性和容错性。
- Topic：数据在 Kafka 中是通过主题组织的。生产者将数据发送到主题中，消费者从主题中读取数据。主题可以分为多个分区（Partition），分区使得主题能够水平扩展，以提高吞吐量和并行处理能力。
- Partition：每个主题都可以被分为多个分区，分区是 Kafka 中的基本并行单元。每个分区中的消息是有序的，但是跨分区的消息没有全局顺序。通过分区，Kafka 能够在集群中分布负载，并实现高并发的数据处理。
- Zookeeper：Kafka 使用 Zookeeper 来管理集群的元数据、Broker 状态、主题配置等信息。在新的 Kafka 版本中，Zookeeper 被逐渐替代为 Kafka 自带的集群协调功能，但在旧的版本中，Zookeeper 是必需的。
- Leader 和 Follower：每个分区都有一个 Leader 和若干 Follower。Leader 负责处理生产者和消费者的读写请求，而 Follower 只负责同步 Leader 中的数据。当 Leader 失效时，Kafka 通过 Zookeeper 或自带的协调功能选举新的 Leader。
