我正在尝试从kafka经纪人向akka流图提供数据（例如10个字符串）
这是单元测试中的图表：
<pre><co
我正在尝试使用Consumer.committableSource使用Akka从Kafka读取数据。然后，我想将数据写入共享文件夹中的文件
如果有异常，我正在使用RestartSource.onFailuresWithBackoff重新启动Source，但是如果接收到某种异常类型，我想
我正在寻找一种将对象流式传输到Solr Cloud的方法。唯一的问题是对象本身以Solr集合名称的形式包含有关
我正在运行实时视频流服务器。有一个<code>Array[Byte]</code>视频源。请注意，我无法与视频源建立2个连接
我必须将Socket应用程序转换为akka，但似乎没有响应。我是akka的新手，修改示例似乎无效。
使用普
我在 play framework2.6 上创建了 WS 客户端，它连接到 REST API。这个 rest API 不断地发送数据块/数据流。但随
我是 akka 流的新手，想了解流中的物化是如何工作的
<pre class="lang-scala prettyprint-override"><code>//Print sum
了解如何计算流中每个元素的比率（百分比）。
<code>(10,20,30,40,50)->(10/150, 20/150, 30/150, 40/150, 50/150
我试图在运行 streamlets 时访问资源文件夹下的文件。
下面是我的 sbt 结构。
<a href="https://i.stack.imgur
我在 s3 存储桶中有 Avro 文件并尝试流式传输和解析为案例类。
我有要解析的架构，但不知道如何处理。
我是 Akka 和 Scala 的新手，我自学了用 websockets 做一个小项目。最终目标很简单，做一个基本的聊天服务
我正在尝试使用 SQS 源和使用 Localstack 进行测试来实现一个简单的工作流程。
如果我添加 <code>SqsAckSink</c
我的系统中有一个流程，它从 SQS（使用 alpakka）读取一些元素并进行一些预处理（约 10 个阶段，通常总
我正在为我的应用程序使用 scala 和 akka 流，最后想将记录插入雪花。
是否可以使用 slick jdbc 或 alpa
我目前正在使用 Akka 项目，该项目由一个 5 节点 Akka 集群组成。当我们第一次设置项目时，我们决定将
我正在尝试 Akka Stream API，但我不知道它为什么会抛出 java.lang.IllegalArgumentException。
<pre class="lang-scala p
正如 <a href="https://www.lightbend.com/blog/alpakka-kafka-flow-control-optimizations" rel="nofollow noreferrer">here thanks to Sean Gl
我正在使用 lightbend cloudflow 开发我的应用程序，该应用程序使用外部 kafka 主题。
外部 kafka 主题包
我想计算 akka 流完成所需的时间
object Demo 扩展 App {
<pre><code> implicit val system = ActorSystem("MyDemo&
