Kafka Streams KTable join Tombstone

Question

我面临的问题是，我们有联接，并且有多种逻辑方法来生成用于删除KTable中记录的tombstone。

是否可以确定tombstone是ktable联接的结果，而不是显式tombstone？

Answer 1

我可以考虑区分tombstone的一种方法，即一个作为ktable join的一部分出现，另一个作为explicit tombstone发送，就是在explicit tombstone消息中设置一个额外的头属性，然后消费者可以读取这些头以确定tombstone来源。