2017-01-06 3 views
0

Spring Cloud Stream Kafkaを使用し始めました。Spring Cloud Stream Kafkaを使用して受信したイベントデータの集計を計算します

私は単純なプロデューサとコンシューマアプリケーションを作成しました。これはSpring Cloud Stream Kafkaでうまく動作します。

トピックを介して受け取ったイベントデータに対して集計(SUM、AVG)を計算し、Kafkaで保持する必要があります。

計算された集計は、UIでRequest-Responseレイヤーを介して配信されます。

Springクラウドストリームおよび/またはKafkaで集計がサポートされているかどうかを知りたいです。

また、データをKafkaからMongoストアに移動し、集計クエリを実行して(OR)集計を計算し、生データの代わりにmongoデータストアに保存することも検討しています。

誰かが同様のシナリオで作業している場合は、私がどのように進めるかについてのあなたの考えを教えてください。

答えて

0

reactiveこれらのアグリゲーション、ウィンドウ演算子をそのまま使用できるSpring Cloud Streamアプリケーションを利用できます。 Hereはそのようなアプリケーションの例です。

関連する問題