在集群节点上运行的 Akka Streams

Question

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

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

我将如何实现将 akka 集群与流一起使用？我是否必须让 GraphStage 将其工作“外包”给远程参与者？或者graphStage本身可以在集群节点上运行吗？

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

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

Answer 1

akka-streams 还不支持集群。如果您需要一些集群解决方案，我建议将Apache Kafka 视为传输中间件，以及reactive-kafka。但是，当然，您可以使用 actor 实现自己的传输层并在 Akka 集群中运行它。