scalaz-stream - 有没有办法使用 http4s 将从 http 端点接收到的数据直接流式传输到 kafka？

Question

http4s 使用 scalaz 流，并且有针对 kafka 的 scalaz 流实现。我们可以直接将在 http 端点接收到的数据流式传输到 kafka 中，http 端点是源，kafka 是接收器。

喜欢，

Source(HttpStream).map(...).to(Sink(kafka)