zoukankan      html  css  js  c++  java
  • 简单模拟flume

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

        

        数据已经读到了:

        

        

       

      

  • 相关阅读:
    PHP 速度测试函数
    ajax的简单应用之快速入门
    PHP漏洞详解
    jQuery Ajax 实例 全解析
    2007年最后的一天
    近来心情格外的郁闷
    使用 Ajax 实现 lightbox
    GridView删除,编辑应用
    完美的wsus客户端注册表文件
    VISTA桌面显示Internet Explorer
  • 原文地址:https://www.cnblogs.com/fishperson/p/10520411.html
Copyright © 2011-2022 走看看