flume整合kafka外加操做代碼及配置文件!!親測有效

我此次寫的是我在學習完flume和kafka以後作的一個Demo,並且在flume採集完成以後,加上一個kafka能起到消峯緩衝的效果 首先須要的兩大組件及其版本web Kafka2.11 Flume1.7 (jdk1.8 scala2.11) 固然具體的安裝我就不作過多的解釋了, 我是在本地的idea使用log4j本身建立信息: 在此以前咱們須要建立一個properties文件(以下圖): 而後
相關文章
相關標籤/搜索