Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
Akka Streams flatMapConcat 在创建新源时停止以前的源
我有一个用例，我有一个提供服务“地址”的源。然后我想将该地址映射到从该服务传输数据的源。现在，万一我会得到......
如何捕获最大RestartSource后alpakka kafka源流失败
如何捕获最大重启次数后RestartSource的错误？ 我想在源失败最大次数后做一些事情。 我可以看到源正在重新启动...
Actor 集群具有 WeaklyUp 成员，导致集群响应速度太慢
需要一些有关 Auto Downing 和 WeaklyUp Members 的说明。 我们有 5 个节点集群。 2节点集群节点 3 Node Proxy节点（Shard Region代理）。 我们将数据从代理发送到 Cluster Node.Bef...
我们已在微服务中从 akka 更改为 pekko，但是当尝试安装新的微服务（该微服务应该替换在 kubernetes kluster 中运行的微服务）时，我们收到此错误： 没有根gu...
我们正在开发一个具有 akka 持久性的事件源应用程序，使用 Oracle 数据库作为事件存储。该应用程序已经在生产环境中运行了一段时间。最近我们看到了
我正在尝试将传入的 Source[ByteString, Any] 广播到 2 个不同的流，然后扇入（zip）输出。但是我收到错误“重载方法 ~> 使用替代方案”。 瓦尔
我要解决的是以下情况： 给定一个无限运行的 Akka Stream，我希望能够监视流的某些点。我能想到的最好的办法就是把这些乱七八糟的东西送到哪里......
以下是问题的背景： 有一个 Source，它不断地滴答作响，无法保证滴答的频率 我们想要限制源的最大滴答率（例如，我们
从流中提取 Source[ByteString, Any] 到 2 个接收器中
我正在尝试将传入的 Source[ByteString, Any] 放入 2 个接收器中并尝试在 akka 流图中复制传入流。我想要“is”作为输入流，但不是 t...
有没有办法在akka中发出HTTP CONNECT请求？ 我正在尝试在 akka 中编写一个代理应用程序，并且我发出的每个请求都会收到此错误： 16:10:19.179 [默认-akka.actor.de...
我正在尝试使用“集群中的经典分布式发布订阅”的概念从微服务 A 中的 senderActor 发送消息，我正在尝试将消息发布到 co...
Flow.batch 有逆向吗 我希望该方法的签名为 Flow[Vector[T],T,NotUsed] 它应该解包一个 Vector 并将 Vector 的每个元素作为单个元素发送到下游。
Scala-3.3.0：dotty.tools.FatalError：无法解析对
我在 scala-3.3.0 和 akka（或 pekko）中看到此错误： dotty.tools.FatalError：无法解析对 akka.stream.scaladsl.type.Source 类型的引用 dotty.tools.FatalError：无法解析引用...
我们希望在 akka 流关闭时完成以下任务 源头停了， 流中的元素在超时点之前已完成 然后流/演员系统关闭 我们有...
我在Flutter中的info.plist中添加了依赖，但还是不行
我正在开发一个考试项目。我使用 Akka HTTP 创建了一个服务器并使用 postman 进行了尝试。一切正常。但是当我尝试使用 Flutter 发送请求时（顺便说一句，这是第一次......
我正在使用 TypeSafe 配置。想象一下，我希望为弹性模式提供应用程序范围的默认值，但专门在较低的配置级别覆盖它们。我更希望有一个通用的解决方案...
我们正在使用Akka（使用JAVA）框架将消息发送到后端服务器。我们的应用程序在5-6小时内工作正常，发送了大约160万条消息。然后它变得没有响应。
我正在使用 akka 流从 TCP 端点消耗 ByteString 流。数据块应该形成一个或多个 XML 文档。我希望我的流输出带有完整 Xml 的 ByteString。 例如...
[WARN]：非法请求，响应状态为“501 Not Implemented”：不支持的 HTTP 方法：PROXY
启动 ActorSystem 时，会生成以下警告： logMessage="非法请求，响应状态为'501 Not Implemented'：不支持的 HTTP 方法：PROXY"，logS ...