AmazonDMS能在更改为Kafka之前和之后生成记录的状态吗

Question

我们正在试验使用AmazonDMS作为Debezium的替代方案，以对Kafka进行SQL Server数据库更改。一切都很顺利，但我们将在DMS中错过Debezium的一个功能：Kafka中的消息能够在更改之前和之后包含记录的状态。似乎使用DMS时，您只会得到记录的后版本，而不是前版本。有这样的背景吗？我还没有找到任何表明存在的文档，但我想在我放弃之前，我会询问Stack Overflow hivemind。

Answer 1

您可以尝试使用beforemage任务设置来获取before-image数据记录，该数据记录将为您提供带有指定前缀和后缀的列名的before-record值。在任务设置中添加以下转换规则以获得所需的输出。

{
"rule-type": "transformation",
"rule-id": "2",
"rule-name": "2",
"rule-target": "column",
"object-locator": {
"schema-name": "%",
"table-name": "employees"
},
"rule-action": "add-before-image-columns",
"before-image-def": {
"column-prefix": "BI_",
"column-suffix": "",
"column-filter": "pk-only"
}
}