CODEWITHSUNDEEP
apache-kafkaconfluent-platformdebezium
ASHISH M.G
ASHISH M.G

Reputation: 802

Avoid Tombstone Event in Debezium - Kafka

Im using Confluent Kafka and Debezium Postgres Connector in Confluent Control Center to CDC to a Kafka Topic. I see that on delete event Debezium creates two records in the topic.

  1. One with Key and Value as null
  2. Second with "before" state filled in

I would like to avoid Debezium from writing the First record with Key filled and value as null .

I tried setting following property in the Connector :

tombstones.on.delete=false

But this doesnt seen to have any effect.

Upvotes: 0

Views: 3275

Answers (1)

Diego Lopes
Diego Lopes

Reputation: 21

I have the same settings but I run kafka connect in local.

I solved it by using ‘ TombstoneHandler’: https://docs.confluent.io/platform/current/connect/transforms/tombstonehandler.html

Upvotes: 2

Related Questions