Hi all, 我们有一个场景,是把oracle数据通过debezium-oracle-cdc插件抽到kafka中,后面接flink sql分析,现在遇到一个时区的问题,比如数据库中有一个timestamp类型的字段,值是‘2022-11-17 16:16:44’,但是debezium处理的时候用了int64保存,还不带时区信息,变成1668701804000,导致flink sql中用FROM_UNIXTIME处理后变成‘2022-11-18 00:16:44 ’,差了8小时,需要手工再减8h。请问有没有一种统一的方式处理这种情况?
Best