1、本次使用的是flink-sql-connector-mysql-cdc-3.1.1.jar 测试
说明：由于flink cdc底层使用的是debezium本质问题是debezium 使用的时区写死了UTC.如下图
无法更改
2、直接修改debezium源码，重新打包。从根本上解决问题，经测试兼容mysql,PG 一下是我修改的源码
如果各位时间不一样可以按照自己的方式修改。
3、然后重新打包flink-cdc
1、本次使用的是flink-sql-connector-mysql-cdc-3.1.1.jar 测试
说明：由于flink cdc底层使用的是debezium本质问题是debezium 使用的时区写死了UTC.如下图
无法更改
2、直接修改debezium源码，重新打包。从根本上解决问题，经测试兼容mysql,PG 一下是我修改的源码
如果各位时间不一样可以按照自己的方式修改。
3、然后重新打包flink-cdc
版权声明:
本网仅为发布的内容提供存储空间，不对发表、转载的内容提供任何形式的保证。凡本网注明“来源：XXX网络”的作品，均转载自其它媒体，著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处。
我们尊重并感谢每一位作者，均已注明文章来源和作者。如因作品内容、版权或其它问题，请及时与我们联系，联系邮箱：809451989@qq.com，投稿邮箱：809451989@qq.com