| 定位 | 分布式事件流/消息平台 |
|---|---|
| 核心抽象 | Topic、Partition、Producer、Consumer、Broker |
| 典型用途 | 解耦数据源与加工、削峰缓冲、实时流处理输入输出 |
组成示意
组成示意
Producer → Broker(每个 Partition 一个 Leader + 若干 Follower)→ Consumer
主题 orders 分为 3 个分区,每分区 3 副本分布在不同 Broker 上Kafka 以保留期内的可重放日志为模型:消息按位移读取,消费不会删除消息,删除由保留策略控制。