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
전문가
검토됨 한 달 전
  • 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.

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인