Kafka 从ksqlDB中删除记录

pgky5nke  于 2023-08-02  发布在  Apache
关注(0)|答案(1)|浏览(128)

我已经为表创建了一个Kafka主题和一个模式。主题的保留时间默认为7天。但是在ksqlDB中,记录被一次又一次地追加,旧的记录都在ksqlDB中。我还想从表中删除旧记录。我无法自动删除这些记录。
如何从kSql表中自动删除记录?
我尝试了很多,并试图找到任何地方,但无法找到任何解决方案,在它自动删除记录从Ksql表后保留期。

2sbarzqh

2sbarzqh1#

Ksql不“追加记录”。你的制片人...
Kafka主题中的记录是不可变的,并且不能删除。
要从KTable* 中删除键 *,您需要为给定的键生成一个空值记录;它不是自动的,KTable是从压缩的主题中构建的,因此保留时间不适用

相关问题