我有一个流，使聚合时间使用窗口为5分钟。我能用程序把这个参数从5分钟动态地改为4分钟吗с颂歌？不创建相同的流。我需要从流中做出选择取决于条件，如果数据计数超过1000则等待4分钟，如果少于则等待5分钟。
pcww981p1#
我认为你的要求在ksqldb中是不可能的。听起来您需要的是一种会话窗口，其中会话窗口是基于时间以外的某个因素关闭的，例如基于某个计数。虽然这在ksqldb的高级抽象中是不可能的，但在kafka流中却是可能的。你可以看看。
1条答案
按热度按时间pcww981p1#
我认为你的要求在ksqldb中是不可能的。听起来您需要的是一种会话窗口，其中会话窗口是基于时间以外的某个因素关闭的，例如基于某个计数。
虽然这在ksqldb的高级抽象中是不可能的，但在kafka流中却是可能的。你可以看看。