Akka集群是一种新的（2.1+）功能，允许用户在Akka中间件之上构建集群功能。
我一直在尝试使用推荐的rollingUpdate 加上集群应用程序版本在kubernetes 中部署akka 集群，以便以最短的停机时间实现顺利部署。然而移交过程是
我使用以下 akka 配置启动了 ODL(opendaylight) 集群： 在此输入图像描述 这样，节点(11.128.83.43, 11.128.83.33, 11.128.83.32)组成了一个集群，11.128.83.43是member-1,...
我们可以从shard actor的上下文中创建akka actor吗？
我想了解我们是否可以从分片参与者的上下文（从分片参与者内部）创建一个参与者并将一些工作委托给它？ 如果我从分片演员创建演员，有什么限制吗？...
我在使用 akka 集群时遇到问题。 系统设置：2 个节点，每个节点有 2 个工作参与者实例。所有这些参与者（总共 4 个）都由应用程序中的单个参与者进行跟踪。 问题是...
Actor集群分片中有没有办法实现AT-MOST一次消息传递。 我正在将 Actor 集群分片用于一个用例，其中我有一组集群节点和一组代理节点。 从公关...
Actor 集群具有 WeaklyUp 成员，导致集群响应速度太慢
需要一些有关 Auto Downing 和 WeaklyUp Members 的说明。 我们有 5 个节点集群。 2节点集群节点 3 Node Proxy节点（Shard Region代理）。 我们将数据从代理发送到 Cluster Node.Bef...
我们已在微服务中从 akka 更改为 pekko，但是当尝试安装新的微服务（该微服务应该替换在 kubernetes kluster 中运行的微服务）时，我们收到此错误： 没有根gu...
我正在尝试使用“集群中的经典分布式发布订阅”的概念从微服务 A 中的 senderActor 发送消息，我正在尝试将消息发布到 co...
使用 Akka.Management 可以在不使用种子节点的情况下创建集群。 我正在使用“Akka Cluster”作为我的主要工具包来开发一项服务，并且我正在使用“Akka Cluster Boo...
我想使用ClusterSharing测试一个函数，在某一时刻使用ClusterSharing询问一个EventSourcedBehaviorWithEnforcedReplies。ClusterSharding.get(testKit.system()).init(...)
我最近开始使用akka事件源/集群分片进行开发，由于有了在线资源，我认为我了解了基本概念以及如何使用它创建简单的应用程序。我...
我有一个带有声明的AMQP源和AMQP接收器：List 声明= new ArrayList （）{{add（QueueDeclaration.create（sourceExchangeName））;添加（...
我不确定为群集分片配置Akka Actor，我不太确定的一件事是，是否可以为实体配置多个停止消息以正常关闭。例如，实体...
要求失败：未配置默认日志插件，请参阅'reference.conf'
我在与cassandra一起使用persistentActor期间遇到错误，我什至找不到问题所在，甚至我在应用程序.conf文件中将cassandra添加为日志错误[错误] [04/29/2020 14：55：57.517] [...] >
我正在使用akka群集，并尝试为不同的环境设置两个不同的配置。一个用于我的本地设置，其中我将使用种子节点启动应用程序。第二个用于我的...
如何在集群启动时预启动实体？我已经找到了一种方法，但是我认为这不是正确的方法。它包括将StartEntity（entityId）消息发送到...
我如何创建泛型角色-Actor 和Message 在Akka.Net中？ ] >>
我是否可以创建Actor 类型的actor，以将Message 类型的消息作为输入？简而言之，我正在尝试类似下面的内容。公共类SomeActor ...
我正在使用Akka分片群集在多个节点上分配工作负载，并使用context.watchWith（worker）检测子actor的意外终止。看来如果孩子演员...
我尝试根据页面（https://doc.akka.io/docs/akka-management/current/cluster-http-management.html#api-definition）通过http端点关闭无法访问的节点，但是我尝试了原为...