2016-04-18 142 views
6

我想了解Akka Streams的縮放部分,我在這裏看到了各種回覆,但仍然無法理解如何實現此功能。Akka Streams在羣集節點上運行

有ActorPublisher /訂閱者,據我所知,它們是爲了與流進行交互,但同時它說這些不能是遠程的。

我該如何完成能夠使用akka集羣與流一起?我是否必須讓GraphStage將其工作「外包」給遠程演員?或者graphStage本身可以在羣集節點上運行?

我的用例是有一個管道包含幾個繁重的計算階段與連接和合並,並可能需要分發這些階段的一些階段。

更新
根據這一Crawling the Web with Akka Streams我看到一個圖中不能跨越幾個簇。在這種情況下,水平縮放會怎樣?

+0

你只能在本地使用流。無論你在遠程節點之間做什麼,都必須以「舊」的方式完成。 –

回答

9

阿卡流還不支持集羣。如果您需要某些羣集解決方案,並且reactive-kafka,我建議您將Apache Kafka視爲傳輸中間件。但是,當然,您可以使用演員實現自己的傳輸層並在Akka羣集中運行它。

相關問題