DMS(CDC)如何转换为Kafka Payload格式。

0

【以下的问题经过翻译处理】 你好, 目前我正在使用 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" } } ] }

1 回答
0

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

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

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

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

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

profile picture
专家
已回答 6 个月前

您未登录。 登录 发布回答。

一个好的回答可以清楚地解答问题和提供建设性反馈,并能促进提问者的职业发展。

回答问题的准则