计算使用 Spring Cloud Stream Kafka 接收的事件数据的聚合

Question

我刚刚开始使用 Spring Cloud Stream Kafka。

我制作了一个简单的生产者和消费者应用程序，它与 Spring Cloud Stream Kafka 配合得很好。

我现在需要计算通过主题接收并保存在 Kafka 中的事件数据的聚合（SUM，AVG）。

然后，计算出的聚合将通过请求-响应层在 UI 中提供。

我想知道 Spring Cloud Stream 和/或 Kafka 中是否支持聚合。

我也在考虑将数据从 Kafka 移动到 Mongo 存储，然后在那里进行聚合查询 (OR) 计算聚合并仅将它们而不是原始数据持久化到 mongo 数据存储。

如果有人处理过类似的情况，请告诉我你对我如何进行的想法。

Answer 1

您可以使用reactive Spring Cloud Stream 应用程序，它提供这些聚合、开箱即用的窗口运算符。 Here 就是这种应用的一个例子。