Eclipse Ditto在EKS部署后抛出了Akka例外
我在EKS（Helm Chart）上运行Eclipse Ditto v2.5.0，几天后，服务停止工作。它不会返回任何结果，也不会持续使用新事物。我在日志中找到了以下内容： …
Java Akka API的最大持续时间是多少？
我正在使用Akka Java库（不幸的是，经典版本）。实施容忍策略时，提供类似的片段： private static SupervisorStrategy strategy = new OneForOneStra…
kubernetes内部使用Scala Akka的服务发现
我面临着使用Akka进行服务发现的问题。我最近将我的应用程序从Kubernetes版本1.18迁移到1.21。服务发现在较旧版本上工作正常，但似乎在1.21版上不起作…
如何访问Akka HTTP获取请求的数据？
scala tutorial 给出此示例： HttpRequest(uri = "https://akka.io") // or: import akka.http.scaladsl.client.RequestBuilding.Get Get("https://a…
使用ElasticsearchSource过滤弹性结果
在这里，我正在使用此代码从索引中读取数据，其中时间戳为'= 1656055230028： Source>, NotUsed> source = ElasticsearchSource.create( constructEla…
Akka流停止处理数据
当我运行下面的流时，一旦流运行，就不会收到任何后续数据。 final long HOUR = 3600000; final long PAST_HOUR = System.currentTimeMillis()-HOUR; …
akka-stream隐式更改执行线程
在使用Java+Akka-stream开发应用程序期间，我面临着一种奇怪的行为。 根据我对akka-stream文档处理线程的理解，如果没有明确声明async（）操作员，但…
如何在Akka HTTP Post Endpoint中处理这种类型的JSON请求？
我有一个Scala应用程序，该应用程序包含带有帖子端点的Akka HTTP服务器。 ，我在JSON请求中发送以下3个字段： { "f1": "string1", "f2": "string2", "…
从Akka HTTP迁移到HTTP4-自定义指令
我开始学习HTTP4，在工作中，我们可能需要将Akka HTTP实施的REST API迁移到HTTP4。 例如，我可以定义这样的自定义指令： trait CustomDirectives { de…
如何使用Akka图使用基于演员的源？
我正在尝试通过演员将数据发送到包含风扇的可运行图。 我将源定义为： final Source integerSource = Source.actorRef( elem -> { if (elem == Done.d…
为什么使用HTTP服务器和数据库之间的参与者
我正在遵循Rockthejvm（DanielCiocîrlan）的一个示例： 用于实现API休息，它使用了Akka HTTP。要访问Cassandra，它使用了Doobie。 当请求要创建银行帐…
用Akka作为httpresponse的流文件的流内容
我正在通过Java FileInputStream读取大文件的一部分，并希望将其内容汇回客户端（以Akka httpresponse的形式）。我想知道这是否可能，以及我将如何做…
重新平衡akka群集，如果一个碎片没有解决
间歇性地，我们正在收到以下错误 2022-05-25 08:32:30,691 ERROR app=abc a.c.s.DDataShardCoordinator - The ShardCoordinator was unable to update…
Scala akka可以为持久演员创建词根演员吗？ “默认日记插件未配置，请参见参考。
我在Akka 上努力挣扎，每当我尝试创建持久演员时，我都会得到一个例外，对于一个简单的演员来说，它可以正常工作，但是通过此实现，我会遇到错误。我…
