3回答
我有一个带有单个流/图形的Akka Stream应用程序。我想在源位置测量流量，并每隔5秒记录一次，比如“在最近5秒内收到3条消息”。
浏览 5提问于2017-02-01得票数 4
回答已采纳
我目前正在运行类似于以下内容的Akka streams设置：┌─────────────┐ │例如，我将KafkaSink封装到一个RestartSink.withBackoff中，并将以下属性应用于包装的接收器：
private val decider: Supervision.Decider然而，这个解决方案感觉有点像一种解决办法(例如，记录异常，监控策略)，而且它也没有提供任何关于RestartWithBackoffSink行为
浏览 1提问于2020-03-05得票数 4
1回答
我正在开发一个使用Akka Kafka连接器的Kafka消费者应用程序。我希望消费者并行处理消息。我应该选择哪个消费群体？？如何在消费者端配置并行度？
浏览 16提问于2020-05-06得票数 0
如何通过Akka WebSocket发送活动WebSocket连接的实时计数？看来Akka改变了Akka的前置阶段的运行。
在下面的第一个代码块中，只有当计数是唯一的连接时，计数才会立即发送。任何在计数超过1的情况下进行连接的客户端，在下一个客户端连接之前都不会接收更新。第二个代码块删除了WebSocket代码，因此只使用Akka，并且每个流订阅都会收到一个即时计数，如stdout所示。import akka.stream.scala
浏览 1提问于2017-09-06得票数 1
1回答
在向我无法控制的第三方服务发出请求时，我在日志中遇到了以下异常：at akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:571)
at akka.stream.impl.fusing.ActorGraphInterpreter
浏览 1提问于2017-10-25得票数 0
回答已采纳
我正在学习Akka.NET，我正在尝试创建一个定制的记录器。我跟踪了一个。我一直无法让阿克卡连接我的定制记录器。显然，var sys = ActorSystem.Create("AkkaCustomLoggingActorSystem");行读取Akka并按照设置配置日志记录。在第441行，记录器被设置为BusLogging，我看不到在任何地方使用配置中设置的记录器。
我创建了一个非常简单的Akka.NET项目，目
浏览 1提问于2018-06-26得票数 2
回答已采纳
我目前正在玩Akka和。
可以指定MongoSource的类型吗？
浏览 1提问于2018-03-10得票数 0
回答已采纳
1回答
versions：Scala2.12，akka-http 10.2.4
implicit val system: ActorSystem
浏览 21提问于2022-02-21得票数 0
回答已采纳
现在，我正在使用akka-stream和akka-HTTP来构建一个文件流API。因此，我将流源注入实体中，使数据直接流到HTTP客户端，如下所示：但是，如果由于某种原因流失败，则连接将被akka-http关闭，而无需进一步解释或日志记录。
浏览 0提问于2017-02-16得票数 1
回答已采纳
db.default.poolMaxSize=5play.evolutions.autoApply=trueval onStart = { DBs.setupAll()at akka.stream.impl
浏览 1提问于2019-10-27得票数 12
回答已采纳
3回答
为什么例外情况在import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Source我可以看到，在打印Received 1之后，流就停止了，但是没有任何记录。注意，问题不是一般的日志配置，因为如果我在我的akka.log-config-on-start = on文件中设置了application.conf，我会看到很多
浏览 2提问于2016-02-25得票数 19
回答已采纳
所以我有一个游戏应用程序，有这样的子模块：/modules/notificationsLogger.debugsupervisor actor Iot")在通知中，我有以下文件：
/modules/notificat
浏览 0提问于2019-01-01得票数 1
在JMeter中，当使用“保存文件响应”来存储http响应时，如何在将自定义后缀附加到文件名末尾时增加文件名？这是我的设想
然后，我将记录的流量从记录控制器移到我的主线程组。这使我可以重新运行我的记录。然后，我在HTTP请求采样器中添加了一个“文件的保存响应”，用于我从网站上记录的“下载”
浏览 3提问于2014-01-22得票数 2
回答已采纳
我正在尝试创建一个由多个节点组成的网络的模拟，以分析网络流量。节点本身将使用Akka.Net实现，并且应该能够使用一些Akka.Net集群功能。在单个参与者系统中，是否仍然可以使用集群模块及其功能，如角色、分布式广播、成员上/下事件等？
有没有可能伪造远程部署它们，并创建一个伪造的传输，简单地将所有流量路由回相同的参与者系统？
浏览 27提问于2017-12-21得票数 0
2回答
我们一直很难发现和调查我们的Akka演员在一个2.0.4的应用程序中的错误。logger.akka=DEBUG
loglevel = DEBUG fsm = on
浏览 2提问于2013-03-06得票数 18
我正在尝试使用Exception in thread "main" java.lang.NoSuchMethodError: akka.util.OptionVal} throw new IllegalArgumentException(s"Port $out cannot be accessed in this builder")在akka-stream中(2.11 vs 2.5.12)。该方法确实不存在于<em
浏览 1提问于2018-05-29得票数 0
要实现无阻塞、异步、背压系统，这些都是很好的候选.但是，我经常尝试看看在Akka/ProjectReactor/RxJava/Vertx中，哪一个(几个)是构建反应性系统的最佳选择，也可以实现“反应性宣言就我个人而言，我在很好的水平上使用了Akka，并对项目反应堆/Spring网络流量有了合理的想法。在我的分析中，我看到Akka满足所有的“反应宣言”属性，实际上是建立在这些原则之上的。它提供了一些特性，如并行性、固有并发性(Act
浏览 8提问于2021-12-20得票数 0
org.scalatestplus.play" %% "scalatestplus-play" % "5.0.0" % Test
akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:423)
akka.
浏览 27提问于2020-01-20得票数 0
1回答
在Akka和Akka.Net中，有处理异步内容(如I/O)的，并将消息输送回参与者的消息箱。如何在中做到这一点？
浏览 3提问于2017-11-02得票数 6
回答已采纳
当尝试对Akka.NET中的群集设置进行故障排除时，群集心跳消息将填充日志。0011akka://mysystem/system/cluster/core/daemon#1680718572]初始化DEBUGThread接收Akka.Cluster.GossipStatus
浏览 2提问于2016-08-09得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
