用于处理JVM上的流数据的Akka实现
因为'Akka.jvm-exit-on-fatal-error'为ActorSystem [mpe]启用而关闭JVM java.lang.StackOverflowError：null
我正在开发一个需要接受小于1,00,000阈值的SOAP XML请求的修复程序。这样我们就可以在处理之前验证大型xml文档。现在，我对...感到困惑
我正在努力实现一个 - 相当简单 - Akka流程。以下是我认为我需要的：我有一个服务器和n个客户端，希望能够通过广播消息对外部事件做出反应......
使用Futures，akka流和akka演员在并发环境中与非线程安全服务集成，同时保持背压
我正在使用第三方库来提供解析服务（在我的情况下是用户代理解析），它不是一个线程安全的库，必须在单线程的基础上运行。我想写一个......
我试图弄清楚如何使用Lagom来消费来自通过Kafka进行通信的外部系统的数据。我已经遇到了Lagom文档的这一部分，它描述了Lagom如何服务......
我正在尝试使用流而不是纯粹的actor来处理http请求，我带来了以下代码：trait ImagesRoute {val log = LoggerFactory.getLogger（this.getClass）隐式def ...
我在Akka Streams中使用slick从数据库（postgresql）加载大量记录（~2M）并将它们写入S3文件。但是，我注意到下面的代码适用于〜...
我将一个流作为发布者运行，并将扇出设置为true。现在，如果我从这个发布者开始启动多个流，并且它们具有不同的处理速率，那么akka将处理每个订阅者...
我需要调用cassandra来获取日期，然后将获取的日期传递给另一个要将数据插入数据库的流。 def fetchDate：Future [Done] = readJournal（persistenceKey）...
我正在使用sbt来创建一个akka-HTTP项目。我使用的命令是“sbt new https://github.com/akka/akka-http-java-seed.g8。”但它说找不到模板：https：//github.com/akka/akka -...
我有一个Source，我需要转换成另一个。在此过程中，我还想点击流并将其发送到接收器。这对于toTo和wireTap也没问题。但是，我想做...
在akka流中，可以执行以下操作：Source.tick（0.seconds，15.seconds，“Hello”）并且您的流将每15秒接收一个勾选元素“Hello”。我正在寻找的是......
我们正在尝试使用Akka Streams和Alpakka Kafka来使用服务中的一系列事件。为了处理事件处理错误，我们使用Kafka autocommit和多个队列。例如，...
我有一个调用流的actor。在运行时，它按预期工作，但在测试时，不会调用流。 Actor（缩写）类PaymentProcessorActor（repo：PaymentRepo，...
我有以下源队列定义。 lazy val（processMessageSource，processMessageQueueFuture）= peekMatValue（Source .queue [（ProcessMessageInputData，Promise [...
Akka流滑动窗口控制SourceQueue减少发射到接收器
更新：我把我的问题放在测试项目中来详细解释我的意思================================== ===================================我有Akka源，contiune从数据库读取...
我正在尝试使用Alpakka实现与AMQP代理连接的非常简单的服务。我只是希望它在它被推送到给定的交换机上时将其队列中的消息作为流消耗...
Akka Stream如何确定GraphStageLogic内部是否失败
我有一个节点网络都使用自定义GraphStageLogic实现。我找不到任何API来确定阶段何时抛出异常（例如，无法拉取端口的IllegalArgumentException）。 ......
如何限制Akka Stream每秒只执行一次消息并发送一次？
我有一个Akka Stream，我希望流大约每秒都向下发送消息。我尝试了两种方法来解决这个问题，第一种方法是让生产者在......的开始。
我有一个用例，我想将消息发送到外部系统，但发送此消息的流程采用并返回我不能使用下游的类型。这是传递的一个很好的用例......
将`func（in：Source [A]）：源[B]`转换成`Flow [A，B]`
我正在使用akka-grpc来生成客户端绑定。它们通常具有func [A，B]形式（在：源[A]中）：源[B]，即它们消耗源[A]并提供源[B]。现在，我想转变...