cdc同步mysql，出来的json数据里面有个字段 ts_ms， 存的是这条数据到达flin

要获取MySQL Binlog中每条数据的创建时间，而非其到达Flink的时间（通常由ts_ms字段表示），您需要在配置Flink CDC源时利用Debezium或类似连接器提供的功能来捕获和传递Binlog事件的时间戳。这个时间戳通常被称为source.ts_ms或者直接是ts_ms但代表的是源头的事件时间，与代表处理时间的ts_ms区分开来。

操作步骤

1. 检查并配置Debezium Source:

   • 确保您的Flink作业配置了Debezium MySQL connector作为数据源。
   • 在Flink作业的connector配置中，Debezium会自动包含一个名为source.ts_ms或直接在变更事件中携带时间戳字段，该字段反映了MySQL Binlog事件的实际生成时间。

2. 访问时间戳字段:

   • 在Flink的数据流处理逻辑中，解析从Debezium接收到的JSON数据时，查找包含源头时间戳的字段。这通常是一个包含变更事件所有元数据的部分，如示例所示：

     "source": {
      "ts_ms": 1728528674000
     }
     

     或

     "ts_ms": 1728528674000 // 如果直接位于事件根级别
     

   • 在自定义的DeserializationSchema或使用SQL API时，确保正确映射和提取这个字段。

3. 注意事项:

   • 时区问题: 如之前文档所述，如果发现时间有偏差，确认MySQL服务器与Flink作业的时区设置是否一致，必要时在Debezium配置中指定正确的server-time-zone参数。
   • 字段命名差异: 根据使用的Debezium版本或具体配置，时间戳字段的名称可能有所不同，请参考具体版本的文档进行配置调整。

通过以上步骤，您可以从Flink CDC同步的MySQL Binlog数据中正确地获取到每条变更记录的原始创建时间。