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

        

        数据已经读到了:

        

        

       

      

  • 相关阅读:
    Sed的使用方法简介
    Shell脚本基础
    网络配置与内核模块相关
    RPM管理,计划任务与性能监控
    SSH服务
    LVM与RAID阵列
    网络存储服务器
    FTP服务
    网络安全之iptables防火墙
    MySQL使用笔记(七)排序和限制数据记录查询
  • 原文地址:https://www.cnblogs.com/fishperson/p/10520411.html
Copyright © 2011-2022 走看看