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.

您尚未登入。 登入 去張貼答案。

一個好的回答可以清楚地回答問題並提供建設性的意見回饋,同時有助於提問者的專業成長。

回答問題指南