如何在读取Kafka Source的Apache Beam流处理管道中模拟事件lateness

• 直接修改消息的事件时间字段：生产测试消息时，将消息中你管道用来提取事件时间的专属字段设置为早于当前时间超过「窗口时长+允许迟到阈值」的数值，直接推送至目标Kafka Topic即可触发迟到判定。比如你设置的1分钟滚动窗口+2分钟允许迟到，就生产事件时间为3分钟之前的消息即可。
• 延迟推送测试消息：先构造一批事件时间为当前实时时间的消息，暂不写入Kafka，等待超过你设置的withAllowedLateness时长后再将消息推送到Topic，模拟上游系统故障延迟上报数据的真实场景。
• 管道侧加临时时间偏移：如果不想调整Kafka消息生产逻辑，可以在管道的事件时间提取步骤加临时处理逻辑，给所有提取到的事件时间统一减去「允许迟到时长+1分钟」的固定偏移量，管道就会将正常消息判定为迟到事件，测试完成后删除这段偏移逻辑即可。
• 暂停消费后恢复验证：先正常生产一批带实时事件时间的消息到Kafka，直接停掉Beam消费管道，等待超过允许迟到时长后再重启管道消费这批积压消息，也能触发迟到判定逻辑。

验证时建议给管道配置迟到事件的侧输出流，将所有迟到事件打印日志或写入临时存储，方便你比对withAllowedLateness、触发策略、窗格发射等参数的实际效果是否符合预期。

内容的提问来源于stack exchange，提问作者Fabio