我用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
自动生成列而不迭代所有已知列?
1条答案
按热度按时间pdtvr36n1#
你可以设置
time.precision.mode=connect
-看到了吗https://debezium.io/documentation/reference/1.2/connectors/sqlserver.html#sqlserver-时间值