博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
简单模拟flume
阅读量:4634 次
发布时间:2019-06-09

本文共 802 字,大约阅读时间需要 2 分钟。

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追加日志

    

    数据已经读到了:

    

    

 

   

  

 

转载于:https://www.cnblogs.com/fishperson/p/10520411.html

你可能感兴趣的文章
软考之路-网络攻击:主动攻击和被动攻击
查看>>
《windows核心编程系列》二谈谈ANSI和Unicode字符集
查看>>
知识图谱学习笔记(1)
查看>>
第三方原理
查看>>
同意好友
查看>>
随机映射
查看>>
servlet对mysql数据库的数据增删改
查看>>
Windows窗口的建立
查看>>
简述nodejs、npm及其模块在windows下的安装与配置
查看>>
20150411--Dede二次开发-01
查看>>
+load +initialize
查看>>
[Advance] How to debug a program (上)
查看>>
关于cookie与本地 存储的区别的问题。
查看>>
挨踢项目求生法则-团队建设篇
查看>>
Implement strStr()
查看>>
Linked List Cycle II
查看>>
SOAPUI请求及mockservice 使用
查看>>
JavaScript正则表达式之语法
查看>>
JavaScript总结(七)
查看>>
亚盘分析(十四)
查看>>