Akka Streams在群集节点上运行

LK_*_*K__ 6 scala akka akka-cluster akka-stream

我试图理解Akka Streams的缩放部分我在这里看到了各种回复,但仍然无法理解这个功能是如何完成的.

有一些ActorPublisher/Subscribers,根据我的理解,它意味着与流交互,但同时它说这些不能是远程的.

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

我的用例是有一个包含几个带有连接和合并的重计算阶段的管道,可能需要分配其中一些阶段.

更新
根据使用Akka Streams对Web进行爬网,我发现单个图不能跨越多个集群.在这种情况下横向扩展的方式是什么?

and*_*tov 9

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