2015-10-23 35 views
1

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

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

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

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

回答

0

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

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

+0

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

+0

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

相關問題