java - KTable 数据在 Kafka 中维护多久？或者如何控制时间

Question

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

标签： javaapache-kafkaapache-kafka-streamsrocksdb

Answer 1

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