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

        

        数据已经读到了:

        

        

       

      

  • 相关阅读:
    java spring-mvc + maven + hibernate + mysql 注释
    c# log4net
    c# winform richtextbox 锁屏和滚屏
    socket 客户端
    c# winform插件
    c# 注册全局热键
    c# 请求api获得json数据
    java 把一个文件夹里图片复制到另一个文件夹里
    c# UpdateLayeredWindow异形窗口
    【哈希】身份证问题
  • 原文地址:https://www.cnblogs.com/fishperson/p/10520411.html
Copyright © 2011-2022 走看看