用于处理JVM上的流数据的Akka实现
我有一个mongodb，它每天都会进行数据更新和插入，我想实时获取与更新和插入相关的数据以推送到另一个数据库中，是否可以使用akka来完成它...
我有一个由多个流组成的图，每个流都返回某个错误或实际结果中的一个。该代码使用divertTo以便将所有Lefts发送到与happy -...
是否可以使用Sink.actorRefWithAck发送批量消息？
我正在使用Akka Streams，并且遇到了Sink.actorRefWithAck。我了解它会发送一条消息，并且仅在对上一个.... >>>
我正在尝试将jaxb对象编组为xml字符串，然后使用akka Streams将其写入文件，但是在执行创建的文件后为空。我已经检查了封送处理方法，但是没有...
我正在使用一个接受单个AKKA接收器并用数据填充它的API：def fillSink（sink：Sink [String，_]）是否有一种方法，无需深入研究akka的深度，可以处理两个输出...
我有我周围保持请求之间的Alpakka Elasticsearch下沉。当我的请求，我创建一个HTTP请求的来源和把它转换成Elasticsearch WriteMessages的源代码，...
我有一个外部（即，我不能改变它）的Java API它是这样的：公共接口发件人{无效发送（事件E）; }我需要实现它接受每个事件发件人，转换...
watchTermination没有在阿卡-HTTP流量触发
目前我正在试图建立一个阿卡-HTTP WebSocket连接，可以：广播到所有连接的客户端回答客户的某些请求这是我创造我的流量至今：// ...保持
是否有可能动态地反序列化外部，未知长度的，从阿卡HTTP字节字符串流分成域对象？方面，我称之为输出JSON一个无限长的HTTP终结...
因为'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”。我正在寻找的是......