flume的Agent应用示例
2018-03-22 本文已影响15人
明明德撩码
环境准备
![](https://img.haomeiwen.com/i4176128/dfd6c74b08288132.png)
安装rpm文件
rpm -ivh *.rpm
重启xineted
/etc/rc.d/init.d/xinetd restart
解压hadoop-2.5.0-cdh5.3.6-src.tar.gz
进入到hadoop-2.5.0-cdh5.3.6\hadoop-2.5.0-cdh5.3.6\share\hadoop\mapreduce1\lib下copy4个jar包
![](https://img.haomeiwen.com/i4176128/7b7d52b4cf5e3786.png)
上传到/opt/cdh5.3.6/apache-flume-1.5.0-cdh5.3.6-bin/lib下
复制并新增文件a1.conf
![](https://img.haomeiwen.com/i4176128/c3437209d6d3a58f.png)
启动flume
bin/flume-ng agent \
--conf conf \
--conf-file conf/a1.conf \
--name a1 \
-Dflume.root.logger=INFO,console
说明:此处我的服务启动不起来,是因为我的一个配置--conf-file conf/a1.conf \ 中少一个conf目录。必须是一个目录
![]()
查看端口
netstat -nlp |grep 44444
![](https://img.haomeiwen.com/i4176128/410804913f022523.png)
发送数据
命令:telnet hadoop-senior.beifeng.com 44444
![]()
![]()