debezium时间戳问题,无法转换为本地时区

zynd9foi  于 2021-06-05  发布在  Kafka
关注(0)|答案(2)|浏览(2396)

我们已经做了一些设置,使用debezium复制mysql。时间戳字段正在转换为utc时区,但我们的系统处于cst时区。它在我们的transforms类中给出了utc时间戳。我们无法转换成cst时区。有没有办法不转换成utc时区或者我们可以把它转换回cst时区。

vjhs03f7

vjhs03f71#

对于mysql,我已经使用spi实现了utctimestamp转换器(将时间戳字段从utc转换为local)。https://github.com/aminkr/utctimestampconverter

gzjq41n4

gzjq41n42#

有一个新的用于公共消费的spi,您可以根据您的要求自定义转换处理-https://debezium.io/documentation/reference/1.1/development/converters.html

相关问题