java - 迭代更改 Kafka Stream SessionWindows 的持续时间

Question

假设我有一个带有 SessionWindowing 的 Kafka Stream，例如:

windowedBy(SessionWindows.with(inactivity_time).until(aWeek))

是否可以根据以下记录的到达迭代地更改窗口的非 Activity 时间间隔？

例如，如果我最初使用第一条记录定义了 inactivity_time=360000，如果在 之后没有到达相同键的第二条记录，是否可以修改此值inactivity_time/2？

Answer 1

遗憾的是，内置功能无法实现这一点。

这样做需要您自己实现此自定义功能，例如使用 Kafka Streams 的处理器 API(生成的处理器/转换器，然后您可以将其插入 Kafka Streams 的 DSL)。