【发布时间】:2019-07-18 18:09:43
【问题描述】:
我想实现 Kafka 流滑动窗口并对特定窗口持续时间执行聚合,并为每个窗口只输出一个结果。
现在,我已经从字面上搜索了整个堆栈溢出,但我无法找到与滑动窗口相关的代码实现。
【问题讨论】:
-
如果您可以提供一些示例数据以及所需的输出,那就更好了。
标签: apache-kafka dsl apache-kafka-streams sliding-window
我想实现 Kafka 流滑动窗口并对特定窗口持续时间执行聚合,并为每个窗口只输出一个结果。
现在,我已经从字面上搜索了整个堆栈溢出,但我无法找到与滑动窗口相关的代码实现。
【问题讨论】:
标签: apache-kafka dsl apache-kafka-streams sliding-window
Kafka 本身无法做到这一点,您必须使用其中一个 KSQL
【讨论】: