kafka和flume集成

使用flume+kafka+sparkstreaming進行日誌實時處理,flume做爲kafka的producer,sparkstreaming做爲kafka的消費者。shell flume只有1.6.0和以上的版才能夠和kafka集成,1.6.0以前的版本沒有提供kafka sink這個功能,在kafka中建立一個flumeTopic topic,而後使用flume 監控五個日誌文件,五個文件
相關文章
相關標籤/搜索