DMS(CDC) to Kafka Payload format

1

Hi, Currently am using DMS to capture db changes and sending them to Kafka. Am only interested in data (json values without "data" keyword included) and not metadata. I am following the user guide and specifically the below configuration but not working. Could you please assist. So am only interested in flat json payload with only the data values inserted to table. Example: { "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 回答
1
已接受的回答

Hi,

If I understand correctly, you want only flat json file without the:

  1. data keyword
  2. metadata section

Currently, there is no available way for DMS to migrate with above requirement however, I was able to find internal feature request raised for option removing metadata. There will be no ETA for when this can be available.

Best option for right now is to clean the database as needed before ingest into the consumer.

AWS
支持工程师
Kevin_Z
已回答 2 年前
profile picture
专家
已审核 1 个月前
  • Thanks, By cleaning db as needed however, still the above keywords will be included in payload , which is something we dont need.

  • Hi, sorry for the typo, I mean to say clean the data from Kafka before ingesting into a consumer.

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

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

回答问题的准则