Kafka Streams的WindowStore可以保存多久？

Question

我用类似下面的代码做开窗聚合，统计每分钟事件出现次数。

t.selectKey { _, rawEvent -> "${rawEvent.appid}${rawEvent.eid}" }
                .groupByKey()
                .windowedBy(TimeWindows.of(Duration.ofMinutes(1)))
                .aggregate(
                        { CountWindow() },
                        { _, v, agg ->
                            // 窗口期的事件总数+1
                            agg.total += 1
                            agg
                        },
                        Materialized.`as`<String, CountWindow, WindowStore<Bytes, ByteArray>>("test_window_retentation1")
                                .withValueSerde(GenericGsonSerde<CountWindow> { gson, bytes ->
                                    gson.fromJson(String(bytes))
                                })
                )

然后通过ReadOnlyWindowStore#fetch()查询给定时间段内事件出现的次数，一开始的时候结果是正常的，但是一段时间后当我重启应用，fetch就获取不到窗口数据了，看上去像是历史窗口被丢弃了。

请问这种开窗操作的窗口是不是有个保留时间呢，如果有的话是否可以设置？

Answer 1

不知道你这个问题是否已经解决, 如果还没有解决的话:

• 给你找了一篇非常好的博客，你可以看看是否有帮助，链接：kafka streams中自定义state store实现对状态存储的灵活操作

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^