Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
在Redis pub / sub和Akka Streams中使用SSE的最简单方法是什么？
我想为以下场景流式传输分块服务器发送事件：订阅Redis密钥，如果密钥更改，则使用Akka Streams流式传输新值。如果有......它应该只流
请注意：我是一名Java开发人员，不熟悉Scala（遗憾的是）。我会问答案中提供的任何代码示例都将使用Akka的Java API。我正在尝试使用Akka ......
我正在研究SBT多项目解决方案。现在我有：顶级项目test-env子项目测试 - 核心子项目test-proj1子项目test-proj2层次结构如下：test-env src project ...
我正面临一些关于正确配置的困惑，这些配置设置为能够访问部署到docker容器中的akka 应用程序。虽然我正在运行虚拟机ubuntu VM，但我想...
对于像/ temp / $ a这样的演员使用actorSelection和ask模式
我有一个ActorSystem（例如A），它产生其他ActorSystem（例如B）。当B出现时，它知道A的地址并执行cluster.join（）。一旦，集群加入，演员可以沟通......
我已经通过play-akka配置文件为数据库操作分配了一个专用线程池。现在我正在使用actor系统注入需要此线程池的服务并访问...
我使用Akka HTTP实现了Web套接字。我正在使用Kafka的数据并使用Web套接字发送通知。功能正常，但我陷入了测试用例。 `私人定义...
Akka的PoisonPill是传播给演员的孩子还是孩子只是在没有处理剩下的消息的情况下被停止？ Akka文档不清楚，有类似的答案......
我正在为akka actor模型实现编写单元测试。系统包含需要初始化的类和特征。我的问题在于测试方法。当我嘲笑要求......
我正在阅读一个cassandra事件流，并希望得到最后一个元素。我目前正在这样做：def myData：Future [Long] = readJournal（myPersistenceId）。drop（5）.take（1）.map（...
我是拉格姆的新手。使用Lagom创建了一个hello world微服务。 service-impl对任何类型的db或逻辑没有任何依赖性，只返回一个硬编码字符串。但是当我在尝试的时候......
在“Akka-Streams”中使用`extrapolate`的用例是什么？
我只是尝试在akka-streams中进行混淆和推断。由于混淆对我来说很有意义，我没有得到推断的用例。我们为什么要为下游添加更多工作 - 当......
Akka应用程序到Heroku获取错误：Web进程无法绑定到$ PORT
试图将我的Akka应用程序部署到Heroku代码我有：val httpPort = Properties.envOrElse（“PORT”，“8080”）。toInt val serverBinding：Future [Http.ServerBinding] = Http（）。bindAndHandle（routes，“。 ..
我正在尝试从网站上理解复合流（来自Sink和Source），它们表示如下：有人可以提供复合流的使用示例。 ...
我有以下代码片段，不能编译：import akka.actor.ActorSystem import akka.Done import akka.http.scaladsl.Http import akka.stream.ActorMaterializer import akka.stream ....
在Consumer API中使用createDrainingControl？
我正在浏览Alpakka中Kafka的Consumer API文档。我遇到了这段代码。根据我的理解，使用msg.committableOffset（）提交偏移量。那为什么......