scala - 通过源 [Bytestring] 使用 Akka-http 链 Akka 流式传输 Kafka

Question

我从 Kafka Reactive Streams 消费者那里收到一个文件作为字节字符串，我想将它发送到服务。

是否可以从 Kafka Reactive Stream Consumer 中提取 Source[Bytestring, Any]，这样我就可以将流从 Kafka 链接到 Akka-http，而无需在内存中加载整个 Bytestring 然后执行 akka-http 请求？