我使用Debezium 1.2
我有MSSQL数据库,希望将数据从一个表发布到其他数据库中的许多其他表(Debezium的常见场景(
所以我设置了MSSQL源连接器和JDBC接收连接器。除了一件事,一切都很好。DATETIME
列在使用者的数据库中创建为INT64
。
我在JDBC接收器配置中用这样的代码修复了它:
"transforms.TimestampConverter.format": "yyyy-MM-dd HH:mm:ss.SSSSSS",
"transforms.TimestampConverter.target.type": "Timestamp",
"transforms.TimestampConverter.field ": "date3",
实际上它是有效的,但我必须编写源表的所有列(应该吗?(。如果有多个主题,这是不可能的。
所以问题来了:如何配置sink/source以允许在不迭代所有已知列的情况下自动使用creteDATETIME
列?
您可以设置time.precision.mode=connect
-请参阅https://debezium.io/documentation/reference/1.2/connectors/sqlserver.html#sqlserver-时间值