akka 相关问题

Akka 集群客户端通过服务集群 IP Kubernetes 进行通信

我已经在EKS中部署了akka集群，并且它正在形成一个集群。我正在端口 27520 上对集群进行几次休息调用，并且我正在使用集群客户端将其发送到另一个 akka 集群...

为什么 Scala + Akka Typed App 没有日志输出？

我有一个问题，我的程序中没有任何日志输出。请帮我解决问题并告诉我哪里出错了。 该应用程序是一个聊天应用程序。它由 UserActor、Main、

Akka：currentEventsByPersistenceId 始终为“eventEnvelope.timestamp”返回零

我正在尝试使用 akka-persistence-query 中的 currentEventsByPersistenceId 查询来检索和处理消息表中存储的事件。但是，我遇到了一个问题，

Akka Typed 项目中的类型不匹配

我在 UserActor 中遇到问题，案例 SendMessageToRoom （Actor 的 20 行）： 类型不匹配。必需：UserCommand，找到：RoomActor.BroadcastMessage 这个应用程序是一个聊天应用程序。 UserActor 我...

在 Actor 内创建自定义线程？

当我的基于 akka 的应用程序运行时，有时我会看到以下错误： [错误] [2024-01-02 07:30:41.524] [xxxx.dispatcher-22680] 线程 [xxxx.dispatcher-22680] 中未捕获的错误：无法创建新的 na...

akka-cluster：无法从缩小的节点中删除参与者

我在使用 akka 集群时遇到问题。 系统设置：2 个节点，每个节点有 2 个工作参与者实例。所有这些参与者（总共 4 个）都由应用程序中的单个参与者进行跟踪。 问题是...

Akka 消息传递时序

我正在使用 Scala 和 Akka 进行人工生命模拟，到目前为止我对两者都非常满意。我在时间安排上遇到了一些问题，但我无法完全解释。 此刻，...

在 Akka 类型化事件溯源中，对多个类型化持久实体使用单个数据库（相同的事件日志）是否很常见？

假设在应用程序办公室中有两个EventSourcedBehavior actor 特质 OfficeFridgeCommand 案例对象 OpenFridge 扩展 OfficeFridgeCommand 案例对象 CloseFridge 扩展了 OfficeFridgeComm...

来自具有阻塞操作的迭代器的 Akka 源代码

Source.fromIterator 上的 Akka 文档 (https://doc.akka.io/docs/akka/current/stream/operators/Source/fromIterator.html) 说： 如果迭代器执行阻塞操作，请确保 r...

Actor集群分片实体Actor中最多一次消息传递

Actor集群分片中有没有办法实现AT-MOST一次消息传递。 我正在将 Actor 集群分片用于一个用例，其中我有一组集群节点和一组代理节点。 从公关...

Helm 预升级挂钩可以在滚动更新之前修改 pod-deletion-cost 吗？

我需要以特定顺序部署 k8s 的 pod（例如，扩展到 3 个副本），以确保最旧的成员（我在 Akka / Apache Pekko 集群中的集群领导者）是最后一个要删除的 pod。 .

Akka Streams 递归流程调用

我正在尝试使用 Akka Streams 实现分页。目前我有 case class SomeObject(id:Long, next_page:Option[Map[String,String]]) def chainRequests(uri: Uri): Future[Option[(Uri, T)]] =...

处理分页结果的 Akka Streams 流程未完成

我想实现一个流程来处理分页结果（例如，底层服务返回一些结果，但也表明通过发出另一个请求可以获取更多结果，传入例如...

Proguard - java.lang.IllegalArgumentException：找不到

我刚刚将项目中的 Java 版本从 8 切换到 11，现在我在使用 Proguard 6.2.2 和 sbt-proguard 0.3.0 时遇到问题，并使用以下选项： -不注意， -不要警告， -不要优化， -

基于URL或本地文件限制流

我有一个 akka http API，用户可以将 S3 URL 发送到服务器。然后，服务器从 AWS 服务器启动流并对源执行后续操作。不过我想验证

Akka：按标签和创建时间排列的事件

我有一个使用 Akka 和 Cassandra 进行事件溯源的应用程序。作为 API 响应的一部分，我需要显示发生的特定类型/标签（例如 UpdateEvent）的事件数量...

Scala Akka 快速入门：Java 版本不匹配和编译错误

我对 Scala 和 Akka 比较陌生，是从 Java、Spring 和 REST API 背景过渡的。目前，我正在学习 Akka Actors Quickstart with Scala 教程。 在尝试...

在系统启动时安排重复演员播放2.4.3

我最近开始使用 Scala 和 Play Framework，并且刚刚将我一直在开发的服务升级到 Play 2.4.3。我的最终目标是创建一个每晚启动服务方法的进程......

Akka.net .NET Core 配置

我正在尝试在 ASP.NET Core 7 Web API 中配置 akka.net。 我将 akka.net 配置添加到 appsettings.json 但配置仍然不起作用。我究竟做错了什么？如何配置akka....

Akka 服务器运行后立即停止

我正在尝试按照文档中的方式设置一个简单的 akka-grpc 服务器。 迁移结果匹配 { case Left(异常) => system.log.error(异常, "迁移 sc 时出现异常...