1.flume 需要Java1.7以上版本，然後需要配置好Java環境變數

2.下載軟體。

到Flume官網上http://flume.apache.org/download.html下載軟體包,

wget "http://mirrors.cnnic.cn/apache/flume/1.6.0/apache-flume-1.6.0-bin.tar.gz"

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

3.簡單示例。

修改配置檔案。

cd conf/

cp cp flume-conf.properties.template test.conf  

輸入內容vim test.conf

儲存並退出

啟動flume agent

bin/flume-ng agene --confconf--conf-file conf/flume.conf --name a1 -Dflume.root.logger=INFO,console

3.測試

寫入內容。

vim 1.log

輸入內容 this is a test 儲存並退出。

 cp 1.log /home/chao/txt/

接著就可以在前一個終端看到剛剛採集的內容了

syslog資料測試。

[email protected]:/home/hadoop# echo "hello idoall.orgsyslog"| nc localhost 5140

syslog資料到flume到kafka

配置檔案。

單個source 多個sink。

Source型別。

 Channel 型別。

Sink型別：

配置

1.sinks.k1.sink.rollInterval = 0

每30秒滾動一次檔案。指定0將禁用滾動，並導致將所有事件寫入一個檔案。

a1.sinks.k1.type = file_roll 寫檔案。

a1.sinks.k1.sink.directory = /home/chao/log檔案路徑

a1.sinks.k1.sink.rollInterval = 0 只寫一個檔案。