Kafka Streams KGroupedTable 恢复

Kafka Streams KGroupedTable recovery

假设聚合如下:

stream.groupByKey
      .count()
      .toStream    
      .to(topic)

默认代理保留时间后会发生什么,例如1 周过去了,必须恢复计数操作的本地状态存储?它会丢失因保留而删除的那些密钥的计数吗?

我想我错过了 count 的变更日志主题获取配置 "cleanup.policy"="compact" 的要点,它隐式地将保留设置为无穷大。因此,不会因为保留而删除任何密钥。