DMS（CDC）如何转换为Kafka Payload格式。

Question

【以下的问题经过翻译处理】 你好，
目前我正在使用 DMS 来捕获数据库更改并将其发送到 Kafka。
我只对数据感兴趣（不包含 “data” 关键字的 JSON 内容），而不关心元数据。我正按照用户指南操作，特别是下面的配置，但不起作用。能否请你提供帮助。
我只对仅包含数据值的平面 JSON 负载感兴趣，用于插入表格。
示例：{"prop1":"value1","prop2":"value2"}

{
    "rules": [
        {
            "rule-type": "selection",
            "rule-id": "1",
            "rule-name": "1",
            "rule-action": "include",
            "object-locator": {
                "schema-name": "BW3",
                "table-name": "INT\_TRANSACTIONS"
            }
        },
        {
            "rule-type": "object-mapping",
            "rule-id": "2",
            "rule-name": "DefaultMapToKafka",
            "rule-action": "map-record-to-record",
            "object-locator": {
                "schema-name": "BW3",
                "table-name": "INT\_TRANSACTIONS"
            }
        }
    ]
}

Answer

【以下的回答经过翻译处理】 您好，

如果我理解正确的话，您只想要平面的JSON文件，不包含以下内容：

1. data 关键字
2. 元数据部分

目前，DMS 还没有可用的方法满足上述要求进行迁移，但我找到了内部功能要求，该要求是去除元数据选项。目前还不知道何时才能提供。

现在最好的选择是在吞入消费者之前根据需要清理数据库。

DMS（CDC）如何转换为Kafka Payload格式。

相關內容