CODEWITHSUNDEEP
apache-kafkaapache-kafka-streamstombstone
DharinS
DharinS

Reputation: 83

Kafka Streams KTable join Tombstone

The problem i am facing is we have joins and have multiple logical ways to product a tombstone for deleting a record in the KTable.

Is it possible to determine of if a tombstone was a result of ktable join and not not an explicit tombstone?

Upvotes: 0

Views: 421

Answers (1)

deadzg_devil
deadzg_devil

Reputation: 378

One way I can think of differentiating the tombstones i.e. one occurring as part of the ktable join and another one sent as an explicit tombstone is to set an extra header attribute in the explicit tombstone message and the consumer can then read those header to determine the source of tombstone.

Upvotes: 1

Related Questions