避免德贝齐姆·卡夫卡的墓碑事件

Question

Im使用Confluent Control Center中的Confluent Kafka和Debezium Postgres连接器将CDC连接到Kafka主题。我看到在删除事件中，Debezium在主题中创建了两条记录。

1. Key和Value为null的一个
2. 其次是"；在"；填写的状态

我希望避免Debezium编写Key已填充且值为null的First记录。

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

tombstones.on.delete=false

但这似乎没有任何效果。

Answer 1

我有相同的设置，但我在本地运行kafka-connect。

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