在我们的例子中，接收器是REST端点。支持Kafka => REST端点连接的连接器有哪些？这类似于AWS简单队列或主题的工作方式。
浏览 1提问于2017-06-09得票数 0
我创建了一个整数源(1到100)，并应用了一些流，之后我想将流分为两个接收器:一个用于偶数，另一个用于奇数，但我不知道如何做到这一点。有人能帮我吗？非常感谢！
浏览 0提问于2018-02-03得票数 0
1回答
我在用可重新启动的源和接收器处理akka流中的错误。object Main extends App {
implicit val system: ActorSystem = ActorSystem("akka-streams-system")我首先断开接收器，希望接收器重新启动，并一次又一次地重新处理newVal == 3消息。但是似乎接收器中的错误被抛出了，只有源失败被重新尝试，所以源最终被重新启动并重新处理
浏览 8提问于2022-01-10得票数 1
回答已采纳
使用Akka-Http和Akka-Streams版本2.4，我如何构造一个流，以便它有一个接收器，即一个websocket。例如，我希望有一个源生成随机数，这些数字被过滤，假设保持偶数，然后流到WebSocket作为接收器。
谢谢
浏览 0提问于2016-02-06得票数 1
回答已采纳
使用Scala和Akka Streams。如果愿意，您可以查看代码以及运行它的测试。
我通常尝试开发一个RxJava版本来进行比较，但我在这个版本上卡住了。在Akka Streams中，我可以构建一个图，其中一个源在2个通道上广播，并从这些通道消耗一个慢接收器和一个快速接收器。每个通道可以独立地应用缓冲和节流。因此，我不确定如何应用缓冲和节流，而不影响两个订阅者。Akka Streams和RxJava都是Rx的实现，
浏览 1提问于2016-09-02得票数 2
可以分别使用Source.actorPublisher()和Sink.actorSubscriber()方法从参与者创建源和接收器。但是从actor创建Flow是可能的吗？从概念上讲，似乎没有充分的理由不这样做，因为它同时实现了ActorPublisher和ActorSubscriber特征，但不幸的是，Flow对象没有任何方法来实现这一点。在优秀的博客文章中，它是在Akka Streams的早期版本中完成的，所以问题是在最新的(2.
浏览 1提问于2016-08-24得票数 24
回答已采纳
1回答
Akka Streams文档清楚地指出，为了使流能够运行，它必须有一个源和一个接收器。我不知道是什么强加了这样的限制。将多个源合并为一个从单个流分叉的多个汇的方案都是非常合理的。
浏览 4提问于2017-03-20得票数 2
回答已采纳
1回答
我一直在尝试使用Akka Streams，产生了创建Flows并使用FlowGraphs将它们连接在一起的想法。我知道Akka的这一部分仍在开发中，所以有些事情可能还没有完成，一些其他的部分可能会改变，但有没有可能创建一个不“完整”的FlowGraph --也就是没有附加到Sink上--并将它传递到我的代码的不同部分
浏览 0提问于2014-12-07得票数 1
2回答
我不知道如何立即停止akka stream Runnable Graph？如何使用killswitch来实现这一点？我创建akka streams才几天。在我的例子中，我从文件中读取行，并在flow中执行一些操作，然后写入接收器。我想要做的是，在我想要的时候立即停止读取文件，我希望这可能会停止整个运行的图形。任何关于这方面的想法都将非常感谢。
浏览 9提问于2016-08-03得票数 5
回答已采纳
1回答
:42:20.443] [akka-streams-akka.actor.default-dispatcher-5] [akka://akka-streams/user/channel-actor-420[INFO] [11/11/2017 06:33:03.731] [akka-streams-akka.actor.default-dispatcher-3] [ak
浏览 4提问于2017-11-11得票数 0
回答已采纳
我发现我的Akka Streams程序有意想不到的CPU使用量。下面是一个简单的例子：import akka.stream.ActorMaterializer .to(Sink.ignore)上面的代码段将允许源和接收
浏览 3提问于2018-10-19得票数 6
回答已采纳
我有一个非常简单的流来处理一个文件--只是一个FileIO.FromFile源、一个通过流和一个Last接收器：[DEBUG][17/05/2018 13:55:16][Thread 0004][akka://Demo/user/DATReader/StreamSupervisor-0: Akka.<em
浏览 0提问于2018-05-17得票数 0
1回答
Akka Http请求和响应模式
、、、、
我有一个需求，客户端调用通过akka http创建的post端点。一旦请求在post方法中，我就需要将post对象传递给流(由源、多个流和接收器等组成)，并从接收器获取响应，以便可以将响应返回给客户端。**Source.single(req).runWith(sink)(mat)**
s"<h1>Say hello to akka-http. p=$p</h1>"
浏览 1提问于2019-11-29得票数 0
3回答
我有生成未绑定源并使用它的示例代码： def main(args : Array[String]): Unit = {
.onComplete{ _ => system.shutdown() }}
我想创建实现以下功能的类
浏览 39提问于2015-03-16得票数 25
回答已采纳
我正在使用Akka Streams，我遇到了Sink.actorRefWithAck。据我所知，它会发送一条消息，并且仅在收到前一条消息的确认后才尝试从流中拉入另一个元素。有没有办法用这个接收器批量处理消息？示例:拉出五条消息，只有在前五条消息被确认后才拉出下五条消息。但这将需要接收器更改为使用序列，让我们假设这是不可能的。
浏览 16提问于2019-09-27得票数 0
在akka.net streams中创建队列源后，如何向队列中添加项？created object中没有Enqueue、Add或Offer方法。
浏览 17提问于2019-05-14得票数 1
我在Play应用程序中有一个WebSocket服务器，我想将其移动到akka-http服务。我目前使用的是ActorFlow.actorRef，它是在Akka中不存在的Play的一部分。我如何使用akka-http来做同样的事情呢？我可以使用Sink.actorRef创建一个接收器并在那里处理入站消息，但是源呢？我可以用Source.actorRef创建源，但是如何在实现时访问要向其发送消息的参与者呢？我是否应该使用其他类型的源<em
浏览 1提问于2016-09-20得票数 0
视图本身不记录新消息，而是只从持久性参与者复制的消息流中更新内部状态。
它与 / RX有何不同？
看上去和我很像。
浏览 4提问于2017-03-29得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
