当前位置:首页 > Web开发 > 正文

1、将文件解压到/usr/local [[emailprotected] src]# tar -zxvf apache

2024-03-31 Web开发

  1、将文件解压到/usr/local

[[email protected] src]# tar -zxvf apache-flume-1.6.0-bin.tar.gz -C /usr/local/

  2、创建flume-env.sh文件,并设置jdk路径

[[email protected] 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 [[email protected] local]# vim /usr/local/apache-flume-1.6.0-bin/conf/flume-env.sh

  增加以下配置:

export JAVA_HOME=http://www.mamicode.com/usr/local/java/jdk1.8.0_201

  如下图所示:

技术图片

  3、创建配置文件a3.conf 

[[email protected] apache-flume-1.6.0-bin]# mkdir /usr/local/apache-flume-1.6.0-bin/myagent

[[email protected] 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

[[email protected] 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安置及其启动

温馨提示: 本文由Jm博客推荐,转载请保留链接: https://www.jmwww.net/file/web/30207.html