共计 719 个字符,预计需要花费 2 分钟才能阅读完成。
基本概念
kafka 中的生产过程设计多个概念的配合,理清这些概念的关系,有利于了解 kafka 的生产机制。
角色 | 作用 |
---|---|
producer | 生产音讯,向 kafka 推送音讯,非 kafka 组件之一 |
topic | 逻辑概念,用于组织一类音讯 |
broker | broker 运行着 kafka 实例 |
partition | 存储同一个 topic 的分区(多个分区独特存储一个 topic 的音讯) |
replication | partition 的正本,为保障稳定性,同一个 partition 须要在不同 broker 上设置备份 |
leader | partition 的泛滥 replication 的一个,生产方向其中写入,生产方从中读取 |
follower | partition 除 leader 外的 replication。用于备份 partition 的内容保障稳定性 |
下图直观反映了 kafka 的各种概念的关系。
zookeeper 在 kafka 中的角色
zookeeper 为大型分布式计算提供开源的分布式配置服务、同步服务和命名注册。它能够保障一致性和分区容错性,在 kafka 中 zookeeper 为 broker,producer 和 consumer 提供统一的配置信息。在上面的解说中咱们将会具体展现。
生产过程
- produce 会计算本条音讯须要发送的 partition。
- produce 依据发送的分区,向 zookeeper 获取对应 partition 的 leader 信息,发送音讯到 leader 所在的 broker。
- leader 在本地记录该音讯。
- follower 通过轮询监控到 leader 新写入音讯,被动拉取音讯。
- follower 同步音讯胜利向 leader 发送 ack。
- leader 收到所有 follower 同步的音讯,向 producer 发送确认 ack。
正文完