因为大部分数据的事件时间已经超出我们设定的窗口范围,无法进行正常的聚合计算。...滑动窗口随每新事件移动,滚动窗口按预定间隔移动,但两者移动间隔都不超过窗口大小。滚动窗口移动间隔与窗口大小相等时,相邻窗口没有重叠;滑动窗口移动间隔小于窗口大小时,相邻窗口有重叠。...需维护流状态,如保存最小最大值和新值比较。可通过本地状态实现,每操作一组聚合,如下图。Kafka分区确保同代码事件同分区。每个应用实例获取分配分区事件,维护一组股票代码状态。...Streams 在内嵌的 RocksDB 里维护了两个主题的连接时间窗口,所以能够执行连接操作
乱序的事件
处理乱序和迟到事件的要点:
识别乱序事件:检查事件时间,与当前时间比较,超出时间窗口视为乱序或迟到...重置当前运行的应用程序存在一定风险,并行运行多个版本的应用程序可以最大限度减小风险。
无论采用何种模式,重新处理事件都需要小心谨慎的计划与执行。