akka-stream - akka-streams 是否支持集群？如果是，请分享示例

Question

我在我的应用程序中使用 akka 流来处理实时数据。数据量如此之大，所以我想水平扩展我的应用程序。有人可以帮助我了解 akka-streams 是否支持集群？如果是，请分享示例。

标签： akka-streamakka-cluster

Answer 1

我没有发现任何示例或文档表明akka-stream能够直接在集群模式下运行。但是，您可以部署一些“解决方法”。

与 Akka 集群集成

您可以有一个Flow.map或Flow.mapAsync向集群发送一个传入对象并等待响应。

传入数据的分片

源数据可以通过分片功能分解并发送到并行处理数据的独立服务。每个服务都可以使用单个服务运行，akka-stream但应用程序集群将允许多个流独立运行。