Amazon DMS可以生成Kafka更改前后的记录状态吗？

Question

我们正在试验Amazon DMS作为Debezium的替代方案，以产生对Kafka的SQL Server数据库更改。一切都很顺利，但我们在DMS中会忽略Debezium的一个特性: Kafka中的消息能够包含更改之前和之后的记录状态。就像在DMS中，你只能得到记录的后版本，而不是之前的版本。在什么地方有这样的设置吗？我还没有找到任何文档表明有，但我想我应该在放弃之前问一下Stack Overflow hivemind。

Answer 1

您可以尝试使用beforeimage任务设置来获取之前的图像数据记录，这将为您提供具有指定的列名前缀和后缀的之前记录值。在您的任务设置中添加以下转换规则，以获得所需的输出。

{
      "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"
      }
    }