日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 综合教程 >内容正文

综合教程

(02)Flume安装及其启动

發布時間:2023/12/15 综合教程 27 生活家
生活随笔 收集整理的這篇文章主要介紹了 (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安装及其启动的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。