如何更改流中的 window 时间？

Question

我有一个流，它使用窗口化 5 分钟按时间进行聚合。

我可以使用程序代码将此参数从 5 分钟动态更改为 4 分钟吗？

没有创建相同的流。

我需要根据条件从流中进行选择，如果数据计数大于 1000 则等待 4 分钟，如果小于则等待 5 分钟。

Answer 1

我认为您所问的目前在 ksqlDB 中是不可能的。听起来您需要的是一种会话 window，其中会话 window 是根据时间以外的其他因素关闭的，例如基于一些计数。

虽然这对于 ksqlDB 的更高级别抽象是不可能的，但对于 Kafka Streams 是可能的。你可能想看看那个。