如何更改流中的窗口时间

Question

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

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

不创建相同的流。

我需要从流中进行选择，这取决于条件，如果数据计数超过1000，则等待4分钟，如果少于，则等待5分钟。

Answer 1

我认为您的要求目前在ksqlDB中是不可能的。听起来你需要的是一种会话窗口，会话窗口是基于时间以外的其他因素关闭的，例如基于某个计数。

虽然这在ksqlDB的更高级别抽象中是不可能的，但在Kafka Streams中是可能的。你可能想看看。