akka-stream 相关问题

如何使用 Scala 在 RabbitMq 中设置标头

嗨，我正在尝试使用 scala 中的 akka-stream-alpakka-amqp 库在兔子消息中设置标头，但我无法使其工作并读取存储库，我看不到任何参考或我...

akka 流中`Flow.batch`的逆

Flow.batch 有逆向吗 我希望该方法的签名为 Flow[Vector[T],T,NotUsed] 它应该解包一个 Vector 并将 Vector 的每个元素作为单个元素发送到下游。

Scala-3.3.0：dotty.tools.FatalError：无法解析对

我在 scala-3.3.0 和 akka（或 pekko）中看到此错误： dotty.tools.FatalError：无法解析对 akka.stream.scaladsl.type.Source 类型的引用 dotty.tools.FatalError：无法解析引用...

当我使用 playframework 响应分块的 akka 源时，为什么会发生 java.lang.IllegalStateException？

当我使用 playframework 响应 mp3 音频时。我想使用分块收发器。然后我在 akka 流中创建一个 akka 源来响应。并使用播放 Ok.chunked 结果。但它有一个例外...

关于actor系统和akka流的干净关闭

我们希望在 akka 流关闭时完成以下任务 源头停了， 流中的元素在超时点之前已完成 然后流/演员系统关闭 我们有...

akka 流的 Xml 框架

我正在使用 akka 流从 TCP 端点消耗 ByteString 流。数据块应该形成一个或多个 XML 文档。我希望我的流输出带有完整 Xml 的 ByteString。 例如...

Akka Streams：向 QueueSource 提供 StreamDetachedException

我们有一个 DownloadFileFlow 类，它使用 Akka Streams 和 Akka Http 从不同域下载文件；有时（~50%）在向我们遇到的 QueueSource 提供服务时

akka 2.6.0 中的监督决策策略

我必须通过 supervision.decider 但在 akka 2.6.0+ Materializer 中没有类似的设置。 任何人都可以分享如何在更高版本中编写以下代码： 验证垫：ActorMaterializer =

Android Studio 中的 Akka-Http-client [关闭]

如何在 android kotlin 中使用 Akka HTTP 库...？ 我正在 Kotlin 的 Android Studio 上开发 Akka HTTP 库...但我不知道如何在 android studio 上使用 Akka HTTP 库。我哈...

GraphStage akka的重试机制

如果 postStop() 失败，我们如何重试/重启 graphStage？ 我对 akka 比较陌生，非常感谢您的帮助。 这是我正在尝试做的事情： 来源 .via(音频...

使用SttpBackendStub对流请求进行单元测试。

我有一个返回Source流的请求，我想测试一下，像这样。* class * import sttp.client._ class HttpClient() (implicit sttpBackend: SttpBackend[Future, Source[...

Akka流Kafka消费过程并行化

我正在使用Akka Kafka连接器开发一个Kafka消费者应用程序。我希望消费者能够并行处理消息，我应该选择哪个消费者组 选择消费者？ 我如何能 ...

使用Akka流逐行读取csv文件比使用scala.io.Source有什么好处吗？

我需要处理一个大的CSV文件，但我不能一次性加载完整的文件在内存中。我计划逐行处理文件。我在2种技术之间感到困惑：Akka流和Scala ..: Akka流和Scala...

如何将apache poi xls工作簿直接流到akka-http响应？

是否有办法避免将Apache POI工作簿写到字节数组或临时文件，而只是将其流式传输到akka-http响应中？ val wb = new SXSSFWorkbook(new XSSFWorkbook()) ...建立工作簿...val ...。

Alpakka Kafka流永远不会被终止。

我们使用Alpakka Kafka流来消费Kafka的事件。下面是流的定义。ConsumerSettings consumerSettings = ...

在流媒体停滞时，跳过一部分流媒体

我有一个情况，消息通过一个组件，可能会延迟它们，在压力下，我想跳过这个组件，这样延迟的消息不会超过X个 ...

当使用akka流从S3消耗文件时出现超时异常。

我想用akka流的方式从S3中消耗一堆文件。S3.listBucket(" "，Some(" ")) .flatMapConcat { r => S3.download("

Kafka接收器的HTTP请求源？

如何将播放POST路线连接到Kafka水槽？我找到了https://github.com/jamesward/hello-play-kafka。但是它使用随机数的滴答声源附加到Kafka接收器。1如何制作...

将JSON作为Akka流中的单个实体处理，而不是对其进行迭代

我正在尝试使用Akka流将消费者与生产者联系起来。 while（true）{JsonNode msg = producer.getNextDataEnvelope（）; if（msg == null）{中断; ...

Akka超时异常，但实际上已发送邮件

我正在使用具有以下技术的Scala 2.13堆栈：播放！框架2.8 akka输入2.6.3 alpakka kafka 2.0.3 Akka流作业从Kafka读取事件，要求演员计算...