KTable数据在Kafka中保存多久？或者我怎样才能控制时间

Question

我知道 Kafka 内部使用 RocksDb。 如果我用KTable来存储数据字典，它会在特定时间后被删除吗？如果是这样，我怎样才能让它持续无限时间？

Answer 1

KTables 和底层 RocksDB 状态存储的语义类似于 Kafka 中的压缩主题。保留不是基于时间，而是如果您向输入主题发送带有给定键和空值的消息，则记录将有资格被删除。