計算使用Spring Cloud Stream收到的事件數據的聚合Kafka

Question

我剛開始使用Spring Cloud Stream Kafka。

我做了一個簡單的生產者和消費者應用程序，並且與Spring Cloud Stream Kafka一起工作良好。

我現在有要求計算通過主題接收的事件數據的聚合（SUM，AVG）並堅持在Kafka中。

計算出的聚合將通過請求響應層在UI中提供。

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

我也在考慮將數據從Kafka移動到Mongo商店，然後在那裏做一個聚合查詢（OR）計算聚合，只將它們而不是原始數據持久化到mongo數據存儲。

如果有人已經在類似的情況下工作，請讓我知道你對我如何繼續進行的想法。

Answer 1

您可以使用reactive Spring Cloud Stream應用程序，它提供了這些聚合，開箱即用的窗口操作。 Here是這種應用程序的一個例子。