避免Debezium - Kafka的墓碑事件

Question

我使用合流卡夫卡和Debezium Postgres连接器在汇合控制中心到CDC的一个卡夫卡主题。我看到在delete事件上，Debezium在主题中创建了两个记录。

键和值为空的

2. 第二次填充

前的状态

我希望避免Debezium使用键填充和值为null编写第一条记录。

我尝试在连接器中设置以下属性：

tombstones.on.delete=false

但这并没有产生任何影响。

Answer 1

我有相同的设置，但我运行卡夫卡连接在当地。

我使用“TombstoneHandler”：https://docs.confluent.io/platform/current/connect/transforms/tombstonehandler.html来解决这个问题。