我正在尝试使用kafka streams,并且有以下设置:
- 我有一个现有的kafka主题,其键空间是无界的(但可预测和广为人知)。
- 我的主题具有保留策略(以字节为单位),以使旧记录过期。
- 我想将此主题实现为Ktable,以便可以使用交互式查询API按键检索记录。
是否有任何方法可以使我的KTable“继承”我的主题的保留策略?这样,当主题中的记录过期时,它们在ktable中就不再可用了吗?
我担心将所有记录转储到KTable中并使StateStore无限增长。
我能想到的一个解决方案是将其转换为窗口流,跳跃窗口与记录的TimeToLive相等,但我想知道是否有更本地的更好的解决方案。
谢谢。