Kafka Streams KGroupedTable 恢复
Kafka Streams KGroupedTable recovery
假设聚合如下:
stream.groupByKey
.count()
.toStream
.to(topic)
默认代理保留时间后会发生什么,例如1 周过去了,必须恢复计数操作的本地状态存储?它会丢失因保留而删除的那些密钥的计数吗?
我想我错过了 count 的变更日志主题获取配置 "cleanup.policy"="compact" 的要点,它隐式地将保留设置为无穷大。因此,不会因为保留而删除任何密钥。
假设聚合如下:
stream.groupByKey
.count()
.toStream
.to(topic)
默认代理保留时间后会发生什么,例如1 周过去了,必须恢复计数操作的本地状态存储?它会丢失因保留而删除的那些密钥的计数吗?
我想我错过了 count 的变更日志主题获取配置 "cleanup.policy"="compact" 的要点,它隐式地将保留设置为无穷大。因此,不会因为保留而删除任何密钥。