2016-04-18 9 views
6

Akkaストリームのスケーリング部分を理解しようとしていますが、ここではさまざまな回答がありましたが、この機能がどのように達成されたかはまだ分かりません。クラスタノード上で実行されているAkkaストリーム

私が理解しているところからストリームとやりとりすることを意図しているActorPublisher/Subscribersがありますが、同時にこれらは遠隔にすることはできません。

ストリームと一緒にakkaクラスタを使用することはできますか?私は、GraphStageをリモートアクタにその作業を「アウトソース」させる必要がありますか?または、graphStage自体をクラスタノード上で実行できますか?

私のユースケースには、ジョインとマージを含むいくつかの重い計算ステージが含まれており、おそらくこれらのステージのいくつかは配布する必要があります。

更新
私は一つのグラフは、いくつかのクラスタにまたがることはできませんことがわかり、このCrawling the Web with Akka Streamsによります。この場合、水平方向にどのように変化するのでしょうか?

+0

ストリームはローカルでのみ使用できます。リモートノード間で行うことは、「古い」方法で済ませなければなりません。 –

答えて

9

akka-streamsはまだクラスタリングをサポートしていません。いくつかのクラスタリングソリューションが必要な場合は、の転送用ミドルウェアとしてApache Kafkaを参照することをお勧めします。もちろん、アクタを使って独自のトランスポートレイヤを実装し、Akkaクラスタで実行することもできます。

関連する問題