1.官方说明使用database.serverTimezone属性解决时区问题。可见:https://debezium.io/documentation/reference/1.1/connectors/mysql.html
2.从代码看只有sqlserver有这个配置的属性,mysql-connector没有,所以需要修改代码。
3.涉及相关的模块:debezium-connector-mysql和debezium-core
关键字:ZoneOffset.UTC改为ZoneOffset.of("+8")即可
网友评论