简单模拟flume

Posted 2021-02-14 fishperson

NetCat方式：

　　远程访问的方式进行消息传递

　　配置一个Agent，主要配置三个组件：

　　　　source， channel， sink

　　

　　上图中为什么channel会带s，变成channels？

　　　　可以绑定多个

　　　　　　可以这么写  a1.sources.r1.channels=c1 c2 c3   但是sink只能接收一个

 

　　运行flume：

　　　　

　　当前起的是一个agent 后面配置的是conf，然后是具体的conf路径，a1就是在配置里面写的那个a1，后面是打到终端

　　　　

　　　　flume已经启动了。

　　　　使用telnet来连接master 端口是44444

 　　　　

　　　　给一个输入

　　　　

　　　　结果：消息已经接收到了

　　　　

 

Exec：

　　　　造一个日志路径：

　　　　cd /home

　　　　mkdir -p flume_test/log

　　　　touch logserver.log

　　　　pwd

　　　　新造的日志路径/home/flume_test/log

　　　　

　　　　看一下新的配置：

　　　　

　　　　a1.sources.r1.type = exec

　　　　a1.sources.r1.command = tail -f /home/flume_test/log/logserver.log

　　　　这两处做了改动

 

　　　　启动flume：

　　　　

　　　　这里改了flume_exec.conf  因为我刚才写的配置在这个文件里，而上一个写的在flume_telnet.conf中，所以这里修改了

　　　　模拟log追加日志

　　　　

　　　　数据已经读到了: