实时业务场景很复杂，乱序延迟通常不固定（比如高峰期延迟30秒，低峰期延迟5秒），可以实现WatermarkGenerator接口，自定义水印生成逻辑，比如基于周期生成、基于数据条数生成，灵活适配特殊场景。 一、核心思路（适配动态乱序延迟场景） 针对 “高峰期延迟 30 秒、低峰期延迟 5 秒” 的动