使用Debezium订阅 mysql binlog
Debezium对于Timestamp的处理,会变成字符串,处理的核心代码是:
ZonedDateTime expectedTimestamp = ZonedDateTime.of( LocalDateTime.parse("2014-09-08T17:51:04.780"), ZoneId.of("Asia/Shanghai") ).withZoneSameInstant(ZoneOffset.UTC);
官网上面说,需要设定时区,才能正确解析。通过配置:
"database.serverTimezone":"Asia/Shanghai"
但是实际上,配置了中国时区后,时间会变成格林威治时间,也就是英国London时间。
这就导致了,我的timestamp类型的create_time 差了8个小时。
通过对照源码,将时区配置,配置成,解决:
"database.serverTimezone":"UTC"
不知道是取的mysql的时区,还是系统的时区,还是别的。反正先解决了再说。