在SQLServer上使用JDBCSinkConnector自动创建适当的日期时间类型字段

toe95027  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(409)

我用debezium 1.2
我有mssql数据库,希望将数据从一个表发布到其他数据库中的许多其他表(debezium的常见场景)
所以我设置了mssql源连接器和jdbc接收器连接器。除了一件事,一切都很好。 DATETIME 列创建为 INT64 在消费者的数据库中。
我在jdbc sink config中用这样的代码修复了它:

"transforms.TimestampConverter.format": "yyyy-MM-dd HH:mm:ss.SSSSSS",
        "transforms.TimestampConverter.target.type": "Timestamp",
        "transforms.TimestampConverter.field ": "date3",

实际上,它可以工作,但我必须编写源表的所有列(我应该吗?)。如果有多个主题,这将是不可能的。
所以这里有一个问题:如何配置sink/source以允许crete DATETIME 自动生成列而不迭代所有已知列?

pdtvr36n

pdtvr36n1#

你可以设置 time.precision.mode=connect -看到了吗https://debezium.io/documentation/reference/1.2/connectors/sqlserver.html#sqlserver-时间值

相关问题