| Lambda | 批层 + 速度层 + 服务层,最终以批层为准 |
|---|---|
| Kappa | 单一流链路,口径变更靠重放历史 |
| 取舍 | Lambda 两套逻辑易漂移;Kappa 依赖可重放的数据源 |
Lambda 典型数据流
Lambda 典型数据流
Kafka ─┬─→ 流作业(秒级)──→ 实时视图 ─┐
└─→ 批作业(T+1)──→ 全量视图 ─┴─→ 查询层合并数据可长期重放(Kafka 大保留期或对象存储归档)时 Kappa 更易维护;否则批层仍是兜底。
Lambda 同时跑批处理层与速度层,用批层修正实时结果;Kappa 只保留流处理一条链路,历史重放靠消息保留或存储回放。
| Lambda | 批层 + 速度层 + 服务层,最终以批层为准 |
|---|---|
| Kappa | 单一流链路,口径变更靠重放历史 |
| 取舍 | Lambda 两套逻辑易漂移;Kappa 依赖可重放的数据源 |
Kafka ─┬─→ 流作业(秒级)──→ 实时视图 ─┐
└─→ 批作业(T+1)──→ 全量视图 ─┴─→ 查询层合并