我刚开始使用Spring Cloud流Kafka。
我制作了一个简单的生产者和消费者应用程序，它可以很好地与springcloudstreamkafka配合使用。
我现在需要计算通过主题接收并保存在kafka中的事件数据的聚合（sum，avg）。
然后，计算出的聚合将通过请求-响应层在ui中提供服务。
我想知道springcloudstream和/或kafka是否支持聚合。
我还考虑将数据从kafka移动到mongo store，然后在那里执行聚合查询（或）计算聚合并只将它们而不是原始数据持久化到mongo data store。
如果有人在类似的情况下工作，请让我你知道你的想法，我可以继续。