0

私は Akka Streaming とリアクティブ ストリーミングを初めて使用します。質問があります。残りの API がメッセージを受信して​​ Kafka Bus にドロップし、Kafka ストリーミング コンシューマーがメッセージを最大数に集約することは可能ですか。タイム ウィンドウと答えを再実行しますか?

そのようなシステムをどのように実装しますか？またはどこから始めますか？

ありがとう

4

1 に答える 1