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

Question

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

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

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

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

Answer 1

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

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