akka-stream 相关问题

用于处理JVM上的流数据的Akka实现

如何从Akka事件流构建Akka流源？

当MyActor收到开始消息时，它将运行Akka流，并将接收到的每个项目发布到Akka事件流。 MyActor类（隐式系统：ActorSystem，实现：Materializer，ec：...

scala akka akka-stream

回答 2 投票 0

Akka流vs Apache Flink

[在探索Akka流时，我还遇到了Apache Flink流处理引擎。 Akka流实现反应流并支持背压。因此，如果我必须做出决定...

apache-flink akka-stream

回答 2 投票 0

Alpakka kafka消费者补偿金额

我正在Scala中使用Alpakka-kafka来消费一个Kafka主题。这是我的代码：val kafkaConsumerSettings：ConsumerSettings [String，String] = ConsumerSettings（actorSystem，new ...

scala apache-kafka kafka-consumer-api akka-stream alpakka

回答 1 投票 1

Akka流：使用OverflowStrategy.fail（）模拟失败的流

我是Akka和Akka流的新手。我创建了一个虚拟流，并希望它以异常结束，因为我的map（）函数非常慢，并且我将缓冲区设置为1。所以我的问题分为两部分：为什么...

java akka akka-stream

回答 1 投票 0

将Akka流传递到上游服务以进行填充

我需要调用上游服务（Azure Blob服务）以将数据推送到OutputStream，然后需要通过akka转过来并将其推送回客户端。没有akka（只有servlet代码）...

java stream akka akka-stream

回答 1 投票 6

Scala和Akka HTTP：请求内的请求和线程问题

我对学习Scala，Akka Streams和Akka HTTP并不陌生，因此如果问题太简单，请事先道歉。我想在HTTP请求中执行HTTP请求，就像在下面的...

scala httprequest httpresponse akka-stream akka-http

回答 1 投票 2

使用流vs角色执行定期任务

我正在使用akka / scala / play堆栈。通常，即时消息使用流来执行某些任务。例如，我有一个流，它每分钟都会醒来，从数据库中拾取某些东西，然后调用另一个...

scala playframework akka actor akka-stream

回答 1 投票 0

在Akka流中模拟源

我有一个包装器类AwsS3Bucket，当调用该类时，将返回源Source [ByteString，NotUsed]。在我的单元测试用例中，我模拟了此客户端并执行了必要的断言。 val source = ...

scala mockito akka-stream

回答 1 投票 0

合并具有相同物化值的多个源

akka流中的Combine运算符具有以下签名：def Combine [T，U]（第一个：Source [T，_]，第二个：Source [T，_]，rest：Source [T，_] *）（策略：Int => Graph [...

scala akka-stream

回答 1 投票 1

Alpakka Consumer不使用通过Docker编写的Kafka发送的消息

我已经通过Docker compose运行了Kafka和Zookeeper。我可以使用Kafka终端向主题发送/使用消息，并且可以通过Conduktor监视所有内容。但不幸的是，我不是...

scala apache-kafka akka akka-stream alpakka

回答 1 投票 2

如何从Akka Streams Sink抛出的异常中恢复？

我如何从Akka Streams接收器引发的异常中恢复？简单示例：Source integerSource = Source.from（Arrays.asList（1、2、3、4、5、6、7、8、9））; ...

java scala akka akka-stream

回答 1 投票 0

与elasticmq版本不兼容的Akka-http版本

im试图使用elasticmq-rest-sqs运行sqs服务器：“ org.elasticmq” %%“ elasticmq-rest-sqs”％“ 0.14.7”，我的akka 依赖项是：val akka = Seq（“ com.lightbend .akka“ %%” akka-stream -...

scala playframework akka akka-stream akka-http

回答 1 投票 0

如何以惯用的方式向我的Akka流添加错误日志记录？

我当前正在运行类似于以下内容的Akka流设置：┌─────────────┐┐───────────┐│┌ ──────────────┐││REST端点│──▶│队列...

scala logging akka akka-stream

回答 1 投票 0

akka.streams。您可以发出值的源（类似于monix.BehaviorSubject）

我正在寻找akka.stream.scaladsl.Source构造方法，该方法可让我简单地从不同代码位置发出下一个值（例如，监视系统事件）。我需要类似于...

scala akka akka-stream akka-http monix

回答 3 投票 0

akka.UnsupportedAkkaVersion：Akka的当前版本是[2.5.14]，但是akka-http需要版本[2.5.26]

这里是课程：import akka.Done;导入akka.NotUsed;导入akka.actor.ActorSystem;导入akka.http.javadsl.ConnectHttp;导入akka.http.javadsl.Http;导入akka.http.javadsl.model ....

java gradle akka akka-stream akka-http

回答 1 投票 0

如何减少Akka流中的内存使用量

scala akka akka-stream

回答 1 投票 2

在scala Play框架中，在操作结果中流式传输ByteArrayOutputStream

我正在尝试在scala播放框架中将svg图像转换为jpeg图像。我用蜡染，它工作正常。现在，我想在操作结果中流式传输输出，而不是转换...

scala playframework akka-stream

回答 1 投票 1

是否可以从Reactor Flux或RxJava2 Observable / Flowable到AkkaStreams源使用适配器？

有时有一些库，例如R2DBC，它返回一个Reactive Stream，即Reactor Flux，但是在Http层中，我们需要另一个Reactive Stream，即AkkaStreams Source，它是AkkaHttp ...

akka rx-java project-reactor akka-stream reactor