安装flume伪分布式

上传apache-flume-1.9.0-bin.tar.gz到根目录/root/

进入路径/usr/local/,在该路径下解压apache-flume-1.9.0-bin.tar.gz

tar -zxvf /root/apache-flume-1.9.0-bin.tar.gz
在这里插入图片描述
ls查看是否解压成功
在这里插入图片描述
重命名apache-flume-1.9.0-bin为flume
mv apache-flume-1.9.0-bin flume
在这里插入图片描述
进入/etc/profile/修改环境变量

vi /etc/profile
在这里插入图片描述
添加以下内容:

export 	FLUME_HOME=/usr/local/flume
export PATH=$PATH:$FLUME_HOME/bin

在这里插入图片描述
按Esc键,然后按":wq"保存退出
刷新环境变量
source /etc/profile
在这里插入图片描述
进入路径/usr/local/flume/conf
cd /usr/local/flume/conf
复制一份flume-env.sh.template文件并将其改为flume-env.sh
cp flume-env.sh.template flume-env.sh
在这里插入图片描述
修改flume-env.sh配置文件
vi flume-env.sh
在这里插入图片描述
修改以下内容:
在这里插入图片描述

按Esc键,然后按":wq"保存退出

查看flume版本:
flume-ng version
在这里插入图片描述
进入路径/usr/local/flume/conf
cd /usr/local/flume/conf
在这里插入图片描述
创建agent.conf文件
touch agent.conf
在这里插入图片描述
添加以下内容:
在这里插入图片描述
按Esc键,然后按":wq"保存退出

a1.sources = r1
a1.sinks = k1
a1.channels = c1

a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444

a1.sinks.k1.type = logger

a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100

a1.sources.r1.channels = c1

a1.sinks.k1.channel = c1

启动flume
flume-ng agent --conf conf --conf-file /usr/local/flume/conf/agent.conf --name a1 -Dflume.root.logger=INFO,console
在这里插入图片描述

启动成功
在这里插入图片描述

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐