作爲卡夫卡水槽的REST端點

Question

我是卡夫卡世界的新手。我們正計劃設立Kafka來滿足我們的數據流需求。在我們的例子中，接收器是REST端點。什麼連接器可用於支持Kafka => REST端點連接？這與AWS簡單隊列或主題的工作方式類似。

Answer 1

AFAIK沒有針對Apache Kafka的認證HTTP接收器。爲什麼不簡單地創建一個卡夫卡消費者，併爲每個消息（或消息批次）創建一個REST調用您的服務？

Answer 2

我意識到沒有什麼開箱即用的，但阿卡流很適合這種用例。

源將是一個卡夫卡消息流使用阿卡流-卡夫卡（又名反應性卡夫卡）和宿的阿卡的HTTP客戶端（基於流的變體）中創建： http://doc.akka.io/docs/akka-http/10.0.6/scala/http/client-side/request-level.html#flow-based-variant

集成模式爲阿卡流（開始）以alpakka的名稱記錄： http://developer.lightbend.com/docs/alpakka/current/