Spring Cloud Stream Kafkaを使用し始めました。Spring Cloud Stream Kafkaを使用して受信したイベントデータの集計を計算します
私は単純なプロデューサとコンシューマアプリケーションを作成しました。これはSpring Cloud Stream Kafkaでうまく動作します。
トピックを介して受け取ったイベントデータに対して集計(SUM、AVG)を計算し、Kafkaで保持する必要があります。
計算された集計は、UIでRequest-Responseレイヤーを介して配信されます。
Springクラウドストリームおよび/またはKafkaで集計がサポートされているかどうかを知りたいです。
また、データをKafkaからMongoストアに移動し、集計クエリを実行して(OR)集計を計算し、生データの代わりにmongoデータストアに保存することも検討しています。
誰かが同様のシナリオで作業している場合は、私がどのように進めるかについてのあなたの考えを教えてください。