在使用 debezium cdc 和 elasticsearch(sink) 连接器时，我遇到了这样的问题：当数据库中的数据（行）被删除时，debezium cdc 连接器会理解它并向我们的主题发送带有“__deleted”：true 属性的消息。如果我们将带有此消息的主题下沉到弹性，那么一旦它在数据库中被删除 - kafka 会创建墓碑记录，并且我们的弹性搜索接收连接器也会将其从索引中删除（如果它已经下沉到弹性）。但是，如果我们使用复合键（例如：key = id + '_' + itemId）执行一些更复杂的流，则在 elasticsearch 中不会执行此墓碑文档删除，并且此文档将永远保留在那里。
KSQLDB 中是否有办法明确提及某些消息应被视为墓碑以便从弹性中删除它们？或者也许我做错了什么？