在 SQL 服务器上使用 JDBC 接收器连接器自动创建适当的 DATETIME 类型字段

Question

我使用 Debezium 1.2

我有 MSSQL 数据库，想将数据从一个 table 发布到其他数据库中的许多其他 table（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",

实际上它有效，但我必须写 ALL 列的源 tables（我应该吗？）。万一有多个主题就不可能了。

那么问题来了：我如何配置 sink/source 以允许自动生成 crete DATETIME 列而不迭代所有已知列？

Answer 1

您可以设置 time.precision.mode=connect - 请参阅 https://debezium.io/documentation/reference/1.2/connectors/sqlserver.html#sqlserver-temporal-values

在 SQL 服务器上使用 JDBC 接收器连接器自动创建适当的 DATETIME 类型字段

Autocreation appropriate DATETIME type fields using JDBC Sink Connector on SQL Server

apache-kafka

confluent-platform

debezium