码迷,mamicode.com
首页 > Web开发 > 详细

简单模拟flume

时间:2019-03-12 23:56:45      阅读:203      评论:0      收藏:0      [点我收藏+]

标签:技术   结果   telnet   绑定   server   bsp   exe   输入   pwd   

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

    技术图片

    数据已经读到了:

    技术图片

    

 

   

  

 

简单模拟flume

标签:技术   结果   telnet   绑定   server   bsp   exe   输入   pwd   

原文地址:https://www.cnblogs.com/fishperson/p/10520411.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有 京ICP备13008772号-2
迷上了代码!