我们首先进入bigdata04的目录下
最终配置文件如下:
a1.sources = r1
a1.sinks = k1
a1.channels = c1
# Describe/configure the source
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444
# Describe the sink
a1.sinks.k1.type = logger
# Use a channel which buffers events in memory
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100
# Bind the source and sink to the channel
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1
这个配置文件中的a1表示是agent的名称,还有就是port指定的端口必须是未被使用的,可以先 查询一下当前机器使用了哪些端口,端口的可用范围是1-65535,如果懒得去查的话,就尽量使用偏大一 些的端口,这样被占用的概率就非常低了
Agent配置好了以后就可以启动了,下面来看一下启动Agent的命令
../bin/flume-ng agent --name a1 --conf /data/soft/apache-flume-1.9.0-bin/conf/ --conf-file example.conf -Dflume.root.logger=DEBUG,console
看到下面这张图就表示启动正常
参数解释
--name:指定agent的名字
--conf:指定flume配置文件的根目录
--conf-file:指定Agent对应的配置文件(包含source、channel、sink配置的文件)
-D:动态添加一些参数,在这里是指定了flume的日志输出级别和输出位置,INFO表示日志
使用telnet指定端口
telnet localhost 44444
没有就下载一个
这时Flume就采集道对应端口的信息了
使用jps -m 可以查看指定进程信息
也可以使用ps -ef|grep flume
看个人喜好了