集群节点上的 Akka Streams 运行

Question

我正在尝试了解 Akka Streams 的缩放部分我在这里看到了各种回复，但仍然无法理解该功能是如何实现的。

有ActorPublisher/Subscribers据我了解是为了与流交互，但同时它说这些不能远程。

我如何才能将 akka 集群与流一起使用？我是否必须让 GraphStage "outsource" 将其工作交给远程参与者？或者 graphStage 本身可以 运行 在集群节点上吗？

我的用例有一个包含多个具有连接和合并的繁重计算阶段的管道，可能需要分发其中一些阶段。

更新
根据这个 Crawling the Web with Akka Streams 我看到单个图不能跨越多个集群。在这种情况下水平缩放的方式是什么？

Answer 1

akka-streams 还不支持集群。我建议看看Apache Kafka as middleware for transport if you need some clustering solution, and reactive-kafka。但是，当然，您可以在 Akka 集群中使用 actors 和 运行 实现自己的传输层。