本篇文章主要介紹在windows下使用vmware虛擬機器中的Linux(Centons7)下配置安裝Flume。

目前Flume 的最新版本為1.8，筆者安裝的是1.6，是Flume的一個經典版本，通常在生產環境中使用的就是這個版本，在安裝Flume前，看先它的前置條件 

(1).JDK1.8 

(2).足夠的記憶體 

(3).足夠的磁碟空間 

(4).目錄及檔案要有讀寫許可權

簡要步驟：

①、下載Flume解壓包

②、解壓Flume

③、修改配置檔案

④、配置環境變數

⑤、使用Flume幫助命令、檢視版本

⑥、啟動Flume

⑦、使用Flume

⑧、Flume整合Kafka使用

詳細步驟：

一、Flume下載

從官網下載，或者在linux中使用下面的命令下載，然後解壓

方式1:官網下載地址：http://archive.apache.org/dist/flume/ 

方式2：如果提示沒有 wget 命令， 則使用如下命令安裝即可 ，yum install wget # 使用 root 使用者安裝

wget http://archive.apache.org/dist/flume/1.6.0/apache-flume-1.6.0-bin.tar.gz

二、解壓

 tar -zxvf apache-flume-1.6.0-bin.tar.gz 
 

 三、修改配置檔案

①進入flume的conf目錄下，拷貝flume-env.sh.template然後重新命名為flume-env.sh（圖1）

cp flume-env.sh.template flume-env.sh

②在flume-env.sh中配置jdk

vim flume-env.sh

export JAVA_HOME=/usr/java/jdk1.8.0_151

四、配置環境變數

vim ~/.bashrc 
source ~/.bashrc 


# Flume Environment Variable
export FLUME_HOME=/usr/local/devtool/apache-flume-1.6.0-bin

export PATH=$PATH:$FLUME_HOME/bin
 

完整環境變數 

# Uncomment the following line if you don't like systemctl's auto-paging feature:
# export SYSTEMD_PAGER=

# User specific aliases and functions
export JAVA_HOME=/usr/java/jdk1.8.0_151
export HADOOP_HOME=/usr/local/hadoop        # hadoop的安裝目錄，替換為你的hadoop的安裝目錄
export HADOOP_INSTALL=$HADOOP_HOME
export HADOOP_MAPRED_HOME=$HADOOP_HOME
export HADOOP_COMMON_HOME=$HADOOP_HOME
export HADOOP_HDFS_HOME=$HADOOP_HOME
export YARN_HOME=$HADOOP_HOME
export HADOOP_COMMON_LIB_NATIVE_DIR=$HADOOP_HOME/lib/native
export PATH=$PATH:$HADOOP_HOME/sbin:$HADOOP_HOME/bin
# Zookeeper Environment Variable
export ZOOKEEPER_HOME=/usr/local/devtool/zookeeper-3.4.10
# Flume Environment Variable
export FLUME_HOME=/usr/local/devtool/apache-flume-1.6.0-bin




export PATH=$PATH:$JAVA_HOME/bin:$HADOOP_HOME/sbin:$HADOOP_HOME/bin:$ZOOKEEPER_HOME/bin:$FLUME_HOME/bin

五、檢視Flume 的命令幫助

flume-ng help

 檢視版本資訊

flume-ng version

六、啟動Flume

./bin/flume-ng agent -n agent -c conf -f conf/flume-conf.properties.template -Dflume.root.logger=INFO,console

引數說明： 

–conf：指定flume的配置檔案所在目錄 

–name：指定Agent的名稱 

–conf-file：指定編寫的flume配置檔案 

-Dflume.root.logger：指定日誌級別

flume啟動後，列印的日誌中可以看到如下資訊（部分日誌）

輸入jps命令可以檢視到一個Application的程序，如果有這個程序，說明我們的flume啟動成功了

七、簡單使用Flume

測試（啟動一個telnet程序，telnet 資料輸入）

telnet node1 44444

啟動後在這裡輸入完按回車去flume控制檯檢視輸出即可

檢視Flume控制檯的輸出（Event是Flume資料傳輸的基本單元，由可選的header和一個byte array的資料構成）

2018-08-08 13:55:58,446 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO - org.apache.flume.sink.LoggerSink.process(LoggerSink.java:94)] Event: { headers:{} body: 68 65 6C 6C 6F 0D                               hello. }
2018-08-08 13:55:58,447 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO - org.apache.flume.sink.LoggerSink.process(LoggerSink.java:94)] Event: { headers:{} body: 77 6F 72 6C 64 0D                               world. }

八、Flume整合Kafka使用