如何通過Flume將文件加載到Kafka Producer？

我有一個日誌文件，我試圖通過Flume代理推送給Kafka Producer。我可以直接從本地機器將文件加載到Kafka生產者。但我的用例是使用Flume代理推送給Kafka。如何通過Flume將文件加載到Kafka Producer？

我已經安裝了水槽的啓動並在我的本地@http://localhost:35871

運行，但是，我怎麼通過水槽卡夫卡的數據文件嗎？

任何幫助真的不勝感激。謝謝！！！

2015-10-23 Katie

您必須修改您的FLUME SINK才能將數據轉儲到KAFKA BROKER。
要做好這項工作，你必須包括KAFKA生產者在水槽SINK將會成爲您的KAFKA SINK。

水槽還提供了從1.6版本中，建立KAFKA-SINK。

2015-10-23 13:27:27 Bector

你能解釋一下如何把卡夫卡製作者放在FLUME水槽裏嗎？ – Sweet

@Sweet，請點擊鏈接：https：//github.com/thilinamb/flume-ng-kafka-sink瞭解更多信息。 – Bector

回答