0
点赞
收藏
分享

微信扫一扫

07_Flume案例_官方案例(测试)


07_Flume案例_官方案例(测试)_flume


07_Flume案例_官方案例(测试)_服务端_02


此时flume相当于开启了一个服务端:

07_Flume案例_官方案例(测试)_服务端_03


07_Flume案例_官方案例(测试)_子程序_04


让客户端去连接。

07_Flume案例_官方案例(测试)_flume_05


07_Flume案例_官方案例(测试)_键值对_06


07_Flume案例_官方案例(测试)_子程序_07


07_Flume案例_官方案例(测试)_键值对_08


关闭flume服务 ctrl+c

07_Flume案例_官方案例(测试)_flume_09


07_Flume案例_官方案例(测试)_子程序_10


hook:是钩子程序,一般做收尾工具。先停source,再把sink处理完之后在结束。不要使用kill -9命令,使用kill命令。

kill -9 不会去调用钩子程序

kill 调用钩子程序

07_Flume案例_官方案例(测试)_flume_11


bin/flume-ng agent -c conf/ -n a1 -f job/flume-netcat-logger.conf -Dflume.root.logger=INFO,console

07_Flume案例_官方案例(测试)_flume_12


传参数有两种形式:

第一种:

bin/flume-ng agent --conf conf/ --name a1 --conf-file job/flume-netcat-logger.conf -Dflume.root.logger=INFO,console

07_Flume案例_官方案例(测试)_flume_13


类似于agent或者args[0]

这种就不能调位置

第二种:

07_Flume案例_官方案例(测试)_flume_14


kv键值对的形式,根据key去读value,可以调换位置。

07_Flume案例_官方案例(测试)_子程序_15


第二种方式:

bin/flume-ng agent -c conf/ -n a1 -f job/flume-netcat-logger.conf -Dflume.root.logger=INFO,console

07_Flume案例_官方案例(测试)_键值对_16


07_Flume案例_官方案例(测试)_键值对_17


07_Flume案例_官方案例(测试)_flume_18


所以第二种方式使用的更广泛,因为简洁!!!


举报

相关推荐

0 条评论