Flink CDC时区的问题怎么搞定的？

针对Flink CDC时区问题，可以根据不同的情况采取不同的解决措施：

1. 如果您正在从 MySQL 中读取数据，则可以尝试在 MySQL 数据库端设置时区参数（例如 "sys_time_zone"），让 Flink CDC 按照正确的时区解析日期时间字段；
2. 如果是从其他类型的数据库读取，则可以通过 Flink SQL 中的相关函数来指定时区（例如 "tz()" 函数）；
3. 如果您使用的 API 或者模板语言（例如 Java 或 Python），则可以在代码层面添加额外的逻辑来处理时区问题。

在使用Flink CDC进行数据同步时，如果遇到了时区问题，可以通过以下方式设置Flink CDC的时区：

1. 在cdc.properties文件中设置database.timezone属性。
2. 在sink.properties文件中设置database.timezone属性。

这样，Flink CDC在同步数据时就会使用指定的时区，从而避免因时区不一致导致的数据同步问题。

我之前在2.2版本重写了jsonDebezium那个类，自行修正的时间，此回答整理自钉群“Flink CDC 社区”