我已经为表创建了一个Kafka主题和一个模式。主题的保留时间默认为7天。但是在ksqlDB中,记录被一次又一次地追加,旧的记录都在ksqlDB中。我还想从表中删除旧记录。我无法自动删除这些记录。如何从kSql表中自动删除记录?我尝试了很多,并试图找到任何地方,但无法找到任何解决方案,在它自动删除记录从Ksql表后保留期。
2sbarzqh1#
Ksql不“追加记录”。你的制片人...Kafka主题中的记录是不可变的,并且不能删除。要从KTable* 中删除键 *,您需要为给定的键生成一个空值记录;它不是自动的,KTable是从压缩的主题中构建的,因此保留时间不适用
1条答案
按热度按时间2sbarzqh1#
Ksql不“追加记录”。你的制片人...
Kafka主题中的记录是不可变的,并且不能删除。
要从KTable* 中删除键 *,您需要为给定的键生成一个空值记录;它不是自动的,KTable是从压缩的主题中构建的,因此保留时间不适用