FAQ-数据滞留延迟达到2800多万毫秒(8天)

问题描述/异常栈
Task-139132: 【华存】数据滞留延迟达到2800多万毫秒 https://overmind-project.netease.com/v2/my_workbench/taskdetail/Task-139132 FAQ-数据滞留延迟达到2800多万毫秒 - 图1 Kafka延迟计算规则为:Flink当前时间 - kafka message的时间。从延迟值来看,延迟大小为8小时,基本可以推测是写入kafka的record的时间时区使用了UTC时区。
发现版本
RealtimeMonitor-3.9.14
解决方案
需要确认发送方的时区(TimeStamp)是否是utc,需要改成和flink引擎处理的时区local一致

作者:华柄印