讀取Producer中的數據流並推送到Kafka主題

我想從服務器讀取數據在Producer中監聽數據流併發送到主題。數據來源是客戶端流式RPC客戶端使用提供的流寫入一系列消息並將它們發送到服務器。我發現example其中Producer連接到Twitter客戶端並讀取數據。但是，我的目標是儘快讀取數據，在服務器上監聽Producer中的流併發送到Kafka主題。讀取Producer中的數據流並推送到Kafka主題

是否有任何類似的例子或任何人遇到過這種情況？

任何幫助將不勝感激。

來源

2017-06-20 FindingTheOne

這將有助於瞭解您正在使用的流式RPC機制的具體情況，但作爲第一個端口，我期望看到akka-stream-kafka（又名reactive-kafka），因爲它專爲流式傳輸方案： http://doc.akka.io/docs/akka-stream-kafka/current/producer.html

查看那裏的示例。另外，alpakka是基於akka流的集成模式的一項舉措，但支持的連接器列表到目前爲止有限： http://developer.lightbend.com/docs/alpakka/current/

來源

2017-06-21 07:42:20

您好Michal，我使用gRPC（www.grpc.io/docs/quickstart/go .html）作爲RPC機制 – FindingTheOne

讀取Producer中的數據流並推送到Kafka主題

回答

相關問題