Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
我正在使用akka集群。每次akka创建Actor系统实例时，都会在临时目录下创建大量的aeron-{user}-clustersystem文件，占用了大量空间。请问...
如何在akka中通过ConsistentHashingPool向所有角色广播相同的字符串消息。
我是Akka的新手，被这个问题困扰着。我有4个演员，但不知何故，广播的消息总是去一个演员这里是一个示例代码def hashMapping: ConsistentHashMapping = { ...
我正在使用Akka Kafka连接器开发一个Kafka消费者应用程序。我希望消费者能够并行处理消息，我应该选择哪个消费者组 选择消费者？ 我如何能 ...
所以我明白，如果你给一个死掉的演员发送消息，消息会被转到DeadLetters，但是已经被该演员排队的消息会发生什么。它们是否也会被转发到那里......。
我有一个actor，它从Helper中调用了一个静态方法，我想对其进行模拟： public class ExampleActor extends AbstractActor { public Receive createReceive() { .match(CachedFile.class, ...)。
Akka HTTP：如何让流Http().superPool()在遇到坏的URL时不抛出异常？
我有很多URL，我想用Akka HTTP，用流来获取。这些URLs可能是错误的，或者DNS可能无法解析主机名。在这些情况下，我希望 ...
使用akka-typed，我试图创建一个事件来源的应用程序，在这个应用程序中，对一个actor的命令可以对另一个actor造成影响。具体来说，我有以下情况。RootActor BranchActor...
我使用Scala v2.13.1和AKKA HTTP v10.1.11。我有一个路由，结构如下： def foo(a: String): Directive1[String] = { provide(a) } def bar(a: String): Directive1[String] = { ...
我们使用Alpakka Kafka流来消费Kafka的事件。下面是流的定义。ConsumerSettings consumerSettings = ...
是否可以将持久性行为体与路由器一起使用，如扩大规模？如果你有弹性的持久性行为体，你的事件来源就会出现问题。因此，我想知道如何扩展或 ...
我有一个actor，在actor内部被启动，我想模拟actorB，使消息actorB? GetDataForProcessing(value)不会被发送到actorB，我可以测试单元功能。
我试图在我的测试中拦截异常(带异常信息). 我的测试代码： class Test4 extends WordSpec with Matchers with ScalaFutures with ScalatestRouteTest { "should fail if no valid"...。
我使用AKKA Typed 2.6.5和AKKA HTTP......得到以下错误SLF4J: No SLF4J providers were found. SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http:/www.slf4j...。
intellijscalaplay应用程序未建立 - 端口绑定错误
我无法构建我的scalaplay应用程序。[错误]a.i.TcpListener - Bind failed for TCP channel on endpoint [0.0.0.0:9000] java.net.BindException: 地址已经在使用中：bind at sun.nio...。
我试图运行Akka FSM的示例代码，但我遇到了一些错误 [info] Loading project definition from homeakkafsmproject [info] Loading settings for project root from build.sbt .... [...
我使用Akka HTTP cachedHostConnectionPoolHttps池发送请求作为Akka Streams Flow的一部分： private val requestFlow: Flow[(HttpRequest, HelperClass), Either[Error, String], _] = Http()......
从Cassandra返回有效的JSON数据（Akka HTTP）[重复]
尽管在SELECT语句中使用了JSON标志，但来自Cassandra数据库的数据却以无效的JSON返回。这是我收到的情况。当我的前端接收到这个信息时，它当然会被认为是... ...
如何修改Scala actor返回List[String]？
按照Akka教程https:/doc.akka.iodocsakkacurrenttypedguidetutorial_1.html，我修改了示例代码，每隔3秒发送一条消息给一个akka actor：调度器......。
我想用akka流的方式从S3中消耗一堆文件。S3.listBucket(" "，Some(" ")) .flatMapConcat { r => S3.download("
在actor receive block case中使用符号常数来匹配条件。
我想在actor接收块的情况下使用符号常量来匹配条件。 val str1 = "这只是一个要匹配的演示字符串" val date = OffsetDateTime.parse("some date") def ...