Akka集群是一种新的(2.1+)功能,允许用户在Akka中间件之上构建集群功能。
akka 共存是否支持混合 akka classic 和 akka typed 的节点之间的分布式发布-订阅?
我们有一个用java编写的akka 2.6集群,集群中有两个角色(名为“manager”和“executor”),具有不同的功能。目前都是akka经典。 我们想搬到 akka
我目前正在尝试结合 CQRS 和 akka 事件源来实现类似 git 的存储。写入路径是通过 EventSourcedBehavior actor 实现的(将其称为 GitComm...
我正在学习Akka远程处理和集群。当我尝试向远程 Actor 发送消息时,我没有得到预期的行为。 部署在 localhost:2552 上的远程 Actor 哦...
我一直在尝试使用推荐的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)消息发送到...