akka-cluster 相关问题

Akka集群是一种新的(2.1+)功能,允许用户在Akka中间件之上构建集群功能。

akka 共存是否支持混合 akka classic 和 akka typed 的节点之间的分布式发布-订阅?

我们有一个用java编写的akka 2.6集群,集群中有两个角色(名为“manager”和“executor”),具有不同的功能。目前都是akka经典。 我们想搬到 akka

回答 1 投票 0

如何使用akka事件源读取特定时间点的日志

我目前正在尝试结合 CQRS 和 akka 事件源来实现类似 git 的存储。写入路径是通过 EventSourcedBehavior actor 实现的(将其称为 GitComm...

回答 1 投票 0

Akka 类型演员发现

我正在学习Akka远程处理和集群。当我尝试向远程 Actor 发送消息时,我没有得到预期的行为。 部署在 localhost:2552 上的远程 Actor 哦...

回答 1 投票 0

kubernetes 滚动更新期间 Akka 集群切换

我一直在尝试使用推荐的rollingUpdate 加上集群应用程序版本在kubernetes 中部署akka 集群,以便以最短的停机时间实现顺利部署。然而移交过程是

回答 1 投票 0

如何在不停止服务的情况下迁移Akka集群

我使用以下 akka 配置启动了 ODL(opendaylight) 集群: 在此输入图像描述 这样,节点(11.128.83.43, 11.128.83.33, 11.128.83.32)组成了一个集群,11.128.83.43是member-1,...

回答 1 投票 0

我们可以从shard actor的上下文中创建akka actor吗?

我想了解我们是否可以从分片参与者的上下文(从分片参与者内部)创建一个参与者并将一些工作委托给它? 如果我从分片演员创建演员,有什么限制吗?...

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

Actor 集群具有 WeaklyUp 成员,导致集群响应速度太慢

需要一些有关 Auto Downing 和 WeaklyUp Members 的说明。 我们有 5 个节点集群。 2节点集群节点 3 Node Proxy节点(Shard Region代理)。 我们将数据从代理发送到 Cluster Node.Bef...

回答 1 投票 0

从 akka 更改为 pekko 时,根守护者协议错误

我们已在微服务中从 akka 更改为 pekko,但是当尝试安装新的微服务(该微服务应该替换在 kubernetes kluster 中运行的微服务)时,我们收到此错误: 没有根gu...

回答 1 投票 0

Akka集群收不到消息

我正在尝试使用“集群中的经典分布式发布订阅”的概念从微服务 A 中的 senderActor 发送消息,我正在尝试将消息发布到 co...

回答 1 投票 0

Akka.管理DiscoveryMethod.Config

使用 Akka.Management 可以在不使用种子节点的情况下创建集群。 我正在使用“Akka Cluster”作为我的主要工具包来开发一项服务,并且我正在使用“Akka Cluster Boo...

回答 1 投票 0

特定分片参与者的自定义调度程序

有没有办法为特定的分片参与者分配自定义调度程序?我找到了非分片演员的示例,但没有找到分片演员的示例。

回答 0 投票 0

Akka集群共享--如何测试?

我想使用ClusterSharing测试一个函数,在某一时刻使用ClusterSharing询问一个EventSourcedBehaviorWithEnforcedReplies。ClusterSharding.get(testKit.system()).init(...)

回答 1 投票 0

我如何创建演员来表达akka的层次结构?

我最近开始使用akka事件源/集群分片进行开发,由于有了在线资源,我认为我了解了基本概念以及如何使用它创建简单的应用程序。我...

回答 1 投票 1

Alpakka AMQP:如何检测声明异常?

我有一个带有声明的AMQP源和AMQP接收器:List 声明= new ArrayList (){{add(QueueDeclaration.create(sourceExchangeName));添加(...

回答 1 投票 0

是否可以在Akka群集中定义几个停止消息

我不确定为群集分片配置Akka Actor,我不太确定的一件事是,是否可以为实体配置多个停止消息以正常关闭。例如,实体...

回答 1 投票 0

要求失败:未配置默认日志插件,请参阅'reference.conf'

我在与cassandra一起使用persistentActor期间遇到错误,我什至找不到问题所在,甚至我在应用程序.conf文件中将cassandra添加为日志错误[错误] [04/29/2020 14:55:57.517] [...] >

回答 1 投票 0

Config Profiles Akka群集

我正在使用akka群集,并尝试为不同的环境设置两个不同的配置。一个用于我的本地设置,其中我将使用种子节点启动应用程序。第二个用于我的...

回答 1 投票 1

在Akka Sharding上启动时初始化实体

如何在集群启动时预启动实体?我已经找到了一种方法,但是我认为这不是正确的方法。它包括将StartEntity(entityId)消息发送到...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.