和Lambda架构相比,它去掉了批处理引擎,直接使用流处理引擎,目标是做到流批一体。
Kappa流行的主要原因在于Kafka和Flink的兴起:
Kafka不仅起到消息队列的作用,也可以保存更长时间的历史数据,以替代Lambda架构中批处理层数据仓库部分。流处理引擎以一个更早的时间作为起点开始消费,起到了批处理的作用。
Flink流处理引擎解决了事件乱序下计算结果的准确性问题。
简单和一致推动了技术架构的一次又一次迭代。
和Lambda架构相比,它去掉了批处理引擎,直接使用流处理引擎,目标是做到流批一体。
Kappa流行的主要原因在于Kafka和Flink的兴起:
Kafka不仅起到消息队列的作用,也可以保存更长时间的历史数据,以替代Lambda架构中批处理层数据仓库部分。流处理引擎以一个更早的时间作为起点开始消费,起到了批处理的作用。
Flink流处理引擎解决了事件乱序下计算结果的准确性问题。
简单和一致推动了技术架构的一次又一次迭代。