流式数据如何实现业务毫秒级实时计算？流式数据怎样解决实时数据乱序异常？

前阵子跟一家出行平台的数据负责人聊天，他说了一件事让我印象很深。平台每天产生数千万条订单和轨迹数据，风控系统需要在用户下单后的毫秒内判断这笔订单是否异常。但传统批处理模式下，数据要先落到数仓、再跑ETL、再算指标——等结果出来，订单早就完成了。