window 存储 KSTREAM-FILTER-0000000001 的保留期必须不小于其 window 大小加上宽限期
The retention period of the window store KSTREAM-FILTER-0000000001 must be no smaller than its window size plus the grace period
我有一天 window 最初的宽限期设置为 O。有一个新要求添加 15 分钟的宽限期。
Kafka 流媒体版本：2.1
代码片段-
KTable, JsonNode> profileAgg =
交易
.groupByKey()
.windowedBy(TimeWindows.of(Duration.ofSeconds(86400)).grace(Duration.ofSeconds(900)))
但不知何故我在进程启动时遇到异常。如何延长保留期？
线程异常 "main" java.lang.IllegalArgumentException：window 存储的保留期 KSTREAM-FILTER-0000000001
必须不小于其 window 大小加上宽限期。得到大小=[86400000]，宽限度=[900000]，保留=[86400000]
使用选项 Materialized.retention
添加保留后，此问题已解决
我有一天 window 最初的宽限期设置为 O。有一个新要求添加 15 分钟的宽限期。
Kafka 流媒体版本：2.1
代码片段-
KTable, JsonNode> profileAgg = 交易 .groupByKey() .windowedBy(TimeWindows.of(Duration.ofSeconds(86400)).grace(Duration.ofSeconds(900)))
但不知何故我在进程启动时遇到异常。如何延长保留期？
线程异常 "main" java.lang.IllegalArgumentException：window 存储的保留期 KSTREAM-FILTER-0000000001 必须不小于其 window 大小加上宽限期。得到大小=[86400000]，宽限度=[900000]，保留=[86400000]
使用选项 Materialized.retention
添加保留后，此问题已解决