当我使用Akka时，如果我这样做了，我就会遇到问题，debug.They在调试时无法获得心跳。然后他们就开始不再见面了。 据我所知，如果他在接下来的10秒内没有心跳，他就离开了集群，不能再见面了。我想延长这个期限。例如，如果你不能心跳5分钟，那么你应该离开集群。我正在寻找这样的解决方案。
浏览 23提问于2019-05-23得票数 0
1回答
Akka心跳延迟
、、、、
Kubernetes上的Akka应用程序面临延迟的心跳，即使在没有负载的情况下也是如此。我尝试为集群添加自定义分派器，即使是为每个特定的参与者，但没有帮助。我没有做任何阻塞操作，因为它只是一个简单的Http服务器。 当群集有负载时，节点将变得不可访问。我创建了一个可用于重现该问题的存储库：https://github.com/CostasChaitas/Akka-Demo
浏览 43提问于2019-09-23得票数 0
回答已采纳
1回答
将参与者的数据流到播放结果
、、、、
我有数据到达一个演员的块，并希望返回这些块作为一个流在一个剧本Result。由于从Ok.stream获得响应的唯一方法似乎是理想的候选人，如下所示： (source ?GetStream()).map { }我将从我的参与者返回一个Enumerator[Array[Byte]]，然后当消息到达该参与者时
浏览 6提问于2015-07-09得票数 0
回答已采纳
我在我的SignalR客户端(安卓)上看到了一个奇怪的行为。OnDisconnected事件正在触发，连接失效，但是我的集线器中止了该事件，并将连接id作为新连接重新发出： ? 这似乎发生在Android客户端进入缓慢状态时。它弄乱了我UI上的状态指示器，显示用户仍在连接，但他们已经注销。处理这种情况的最佳方法是什么？当我的连接速度很慢时，我应该停止集线器并重新连接吗？我想过从集线器获取连接id，但没有办法指示连接是活动的还是死亡的。
浏览 34提问于2021-11-18得票数 1
1回答
我在运行我的项目时遇到一个无法解决的错误。下面是我的代码：import akka.actor.Actorimport akka.actor.ScalaActorRefimport akka.pattern.gracefulStopimport java.util.con
浏览 0提问于2014-08-29得票数 1
1回答
我正在使用kafka消费群管理来处理我的信息。[Consumer clientId=consumer-3, groupId=amc_dashboard_analytics] Attempt to heartbeat但对我来说，再平衡只在20分钟前发生。
此外，在运行了几个小时之后，所有分配的消费者都会离开，说“
浏览 2提问于2020-03-19得票数 1
我试图模拟卡夫卡抛出的CommitFailedException。我手动将"session.timeout.ms“设置为10000 ms，将"enable.auto.commit”设置为false。在Kafkaconsumer.poll()之后，我有语句Thread.sleep(12000)，然后执行提交。我预计，由于线程需要12s才能进行下一次投票，因此应该将使用者标记为死掉，并抛出一个CommitFailedException。但是，这个过程执行得很顺利。如何模拟KafkaCons
浏览 1提问于2020-01-31得票数 0
回答已采纳
1回答
我在多个案例中使用这样的select： select { // do something:case <- time.After(time.Second * 5): }我发现，如果highFreqChan获得了大量数据，心跳情况就不会进入，当停止向high
浏览 2提问于2017-12-25得票数 0
回答已采纳
我正在构建一个akka服务，并在配置模式下使用akka发现进行本地测试。我发现，当从为集群创建定义的种子节点切换到发现-机制(akka-发现)时，我的集群单例停止工作。在询问时，我只需从相应的单例中获得一个超时(我使用的是通过代理对该单例进行累积的拟议机制)。我既无法找到解决该问题的方法，也无法</em
浏览 2提问于2018-12-16得票数 0
在akka流中具有流描述，如何修改它以获得一个新的流描述，该描述在开始时执行指定的侧影响，即当流被物化时？
浏览 5提问于2015-12-18得票数 0
回答已采纳
我对Camel的FTP2组件有一个问题，它是生活在Akka系统中的消费者角色。package camelrepro;
import akka.actor.Props;
import akka.camel
浏览 1提问于2013-02-15得票数 2
回答已采纳
1回答
当我启用远程处理启动akka系统时，我会在日志中得到以下行....Remoting now listens on address: [akka.tcp://myactorsystemname@127.0.0.1:4000]
从我的演员，我想打印出akka.tcp://我随身带着ActorSystem对象的一个实例，但我无法解决如何获得这个字
浏览 3提问于2016-05-06得票数 0
回答已采纳
我目前正在运行kafka 0.10.0.1，所讨论的两个值的相应文档如下：
heartbeat.interval.ms -：当使用Kafka的组管理设施时，心跳到消费者协调员的预期时间。心跳用于确保使用者的会话保持活跃，并在新的使用者加入或离开组时促进再平衡。该值必须设置为低于session.timeout.ms，但通常不应高于该值的1/3。session.timeout.ms -用于在使用卡夫卡的组管理工具时检测故障的超时
浏览 8提问于2017-05-10得票数 17
回答已采纳
1回答
我正在阅读这个Akka文档，https://doc.akka.io/docs/akka/current/typed/actor-lifecycle.html#spawning-children，和这个代码片段我的问题是关于这篇文章， replyTo ->
new SpawnProtocol.Spawn<>(HelloWorld.create(), "greeter", Pro
浏览 14提问于2020-11-25得票数 1
2回答
阿克卡骆驼与春天
、、、
我想结合Akka，Apache，Spring，并且不知道如何在同一个项目中利用这三种东西。我成功地2. use camel现在我需要把1和2结合起来。有人能建议我实现这一点的最简单的方法吗？编辑有人说AKKA不再支持，因为下面的链接中的对象实例化存在冲突
此外，也
浏览 4提问于2015-09-23得票数 7
1回答
我读了一些关于如何实现高可用解决方案的文章，使用心跳检查主mysql是否损坏，如果损坏则切换到备份服务器，
一个问题是当主服务器发生故障时，备份服务器继续工作，备份服务器如何获得主服务器的预数据。另一个问题是，也许有时候主服务器没有坏，但mysql服务坏了，在这种情况下，心跳还会切换到备份服务器吗？
浏览 0提问于2011-12-19得票数 0
1回答
我有一个运行在Android设备上的Akka系统，它通过Akka远程处理与服务器上的Akka系统对话。Android设备可以获得任何IP地址，在应用程序运行时IP可能会更改，并且IP可能无法从服务器访问。当服务器和Android设备都在同一个wlan上时，以及当他们通过互联网通过GPRS进行交谈时，这是可行的。
在此场景中，当</
浏览 2提问于2013-04-18得票数 2
回答已采纳
1回答
我已经读过，case类可以与模式匹配一起使用。但是，我也可以使用带有模式匹配的常规类。提供了一个普通的scala透视图。我希望从scala和akka的角度来看这个特定的代码。t
产出如下：Two 200
我知道我在这里遗漏了一些东西，可能是在我对模式匹配的理解中。有人能帮我吗？
浏览 3提问于2017-01-02得票数 4
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
