避免 Debezium 中的墓碑事件 - Kafka

Question

我在 Confluent 控制中心使用 Confluent Kafka 和 Debezium Postgres 连接器来 CDC 到 Kafka 主题。我看到在删除事件中，Debezium 在主题中创建了两条记录。

1. Key 和 Value 为 null 的一个
2. 第二个填写“之前”状态

我想避免 Debezium 写入第一个记录，其中 Key 已填充且 value 为 null 。

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

tombstones.on.delete=false

但这似乎没有任何效果。

Answer 1

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

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