(02)Flume安装及其启动
生活随笔
收集整理的這篇文章主要介紹了
(02)Flume安装及其启动
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
1、將文件解壓到/usr/local
[root@localhost src]# tar -zxvf apache-flume-1.6.0-bin.tar.gz -C /usr/local/
2、創建flume-env.sh文件,并設置jdk路徑
[root@localhost local]# cp /usr/local/apache-flume-1.6.0-bin/conf/flume-env.sh.template /usr/local/apache-flume-1.6.0-bin/conf/flume-env.sh [root@localhost local]# vim /usr/local/apache-flume-1.6.0-bin/conf/flume-env.sh
增加以下配置:
export JAVA_HOME=/usr/local/java/jdk1.8.0_201
如下圖所示:
3、創建配置文件a3.conf
[root@localhost apache-flume-1.6.0-bin]# mkdir /usr/local/apache-flume-1.6.0-bin/myagent
[root@localhost apache-flume-1.6.0-bin]# vim /usr/local/apache-flume-1.6.0-bin/myagent/a3.conf
內容如下:
1 #bin/flume-ng agent -n a3 -f myagent/a3.conf -c conf -Dflume.root.logger=INFO,console 2 3 #定義agent名, source、channel、sink的名稱 4 a3.sources = r1 5 a3.channels = c1 6 a3.sinks = k1 7 8 #具體定義source 9 a3.sources.r1.type = spooldir 10 a3.sources.r1.spoolDir = /usr/local/logs/flumelogs 11 12 #具體定義channel 13 a3.channels.c1.type = memory 14 a3.channels.c1.capacity = 1000 15 a3.channels.c1.transactionCapacity = 100 16 17 #具體定義sink 18 a3.sinks.k1.type = logger 19 20 #組裝source、channel、sink 21 a3.sources.r1.channels = c1 22 a3.sinks.k1.channel = c1
指定source為spooldir,監控的目錄是:/usr/local/logs/flumelogs,如果該目錄下的文件發生變化,就會通過flume把新變化的文件信息采集過來緩存在memory,通過sink指定的logger打印在console(控制臺)
4、啟動flume
[root@localhost apache-flume-1.6.0-bin]# bin/flume-ng agent -n a3 -f myagent/a3.conf -c conf -Dflume.root.logger=INFO,console
啟動成功如下圖所示:
5、測試
新建一個文件,如下圖所示:
移動到/usr/local/logs/flumelogs下,查看控制臺已經打印出信息,如圖所示:
總結
以上是生活随笔為你收集整理的(02)Flume安装及其启动的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 长篇小说《世界上最幸福的人》获得好评
- 下一篇: 世界上最幸福的人