Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
我在 UserActor 中遇到问题，案例 SendMessageToRoom （Actor 的 20 行）： 类型不匹配。必需：UserCommand，找到：RoomActor.BroadcastMessage 这个应用程序是一个聊天应用程序。 UserActor 我...
当我的基于 akka 的应用程序运行时，有时我会看到以下错误： [错误] [2024-01-02 07:30:41.524] [xxxx.dispatcher-22680] 线程 [xxxx.dispatcher-22680] 中未捕获的错误：无法创建新的 na...
我在使用 akka 集群时遇到问题。 系统设置：2 个节点，每个节点有 2 个工作参与者实例。所有这些参与者（总共 4 个）都由应用程序中的单个参与者进行跟踪。 问题是...
我正在使用 Scala 和 Akka 进行人工生命模拟，到目前为止我对两者都非常满意。我在时间安排上遇到了一些问题，但我无法完全解释。 此刻，...
在 Akka 类型化事件溯源中，对多个类型化持久实体使用单个数据库（相同的事件日志）是否很常见？
假设在应用程序办公室中有两个EventSourcedBehavior actor 特质 OfficeFridgeCommand 案例对象 OpenFridge 扩展 OfficeFridgeCommand 案例对象 CloseFridge 扩展了 OfficeFridgeComm...
Source.fromIterator 上的 Akka 文档 (https://doc.akka.io/docs/akka/current/stream/operators/Source/fromIterator.html) 说： 如果迭代器执行阻塞操作，请确保 r...
Actor集群分片中有没有办法实现AT-MOST一次消息传递。 我正在将 Actor 集群分片用于一个用例，其中我有一组集群节点和一组代理节点。 从公关...
Helm 预升级挂钩可以在滚动更新之前修改 pod-deletion-cost 吗？
我需要以特定顺序部署 k8s 的 pod（例如，扩展到 3 个副本），以确保最旧的成员（我在 Akka / Apache Pekko 集群中的集群领导者）是最后一个要删除的 pod。 .
我正在尝试使用 Akka Streams 实现分页。目前我有 case class SomeObject(id:Long, next_page:Option[Map[String,String]]) def chainRequests(uri: Uri): Future[Option[(Uri, T)]] =...
我想实现一个流程来处理分页结果（例如，底层服务返回一些结果，但也表明通过发出另一个请求可以获取更多结果，传入例如...
Proguard - java.lang.IllegalArgumentException：找不到
我刚刚将项目中的 Java 版本从 8 切换到 11，现在我在使用 Proguard 6.2.2 和 sbt-proguard 0.3.0 时遇到问题，并使用以下选项： -不注意， -不要警告， -不要优化， -
我有一个 akka http API，用户可以将 S3 URL 发送到服务器。然后，服务器从 AWS 服务器启动流并对源执行后续操作。不过我想验证
我有一个使用 Akka 和 Cassandra 进行事件溯源的应用程序。作为 API 响应的一部分，我需要显示发生的特定类型/标签（例如 UpdateEvent）的事件数量...
Scala Akka 快速入门：Java 版本不匹配和编译错误
我对 Scala 和 Akka 比较陌生，是从 Java、Spring 和 REST API 背景过渡的。目前，我正在学习 Akka Actors Quickstart with Scala 教程。 在尝试...
我最近开始使用 Scala 和 Play Framework，并且刚刚将我一直在开发的服务升级到 Play 2.4.3。我的最终目标是创建一个每晚启动服务方法的进程......
我正在尝试在 ASP.NET Core 7 Web API 中配置 akka.net。 我将 akka.net 配置添加到 appsettings.json 但配置仍然不起作用。我究竟做错了什么？如何配置akka....
我正在尝试按照文档中的方式设置一个简单的 akka-grpc 服务器。 迁移结果匹配 { case Left(异常) => system.log.error(异常, "迁移 sc 时出现异常...
我想交叉发布我最初在 Akka 用户论坛上发布的问题。 在 Akka 中输入：允许监督接收行为返回新的监督接收的动机是什么
我是 akka 新手，尝试执行以下简单示例： 公共静态无效主（字符串[] args）{ Config cf = ConfigFactory.parseString(" 有界邮箱 { ” +“邮件...
我正在尝试为我的演员编写一些测试用例，问题是一些测试失败了，我无法弄清楚为什么他们失败了。 在正常情况下，我的代码工作正常（没有任何测试......