java - KTable数据在Kafka中保存多久？或者说如何控制时间

Question

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

Answer 1

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