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

        

        数据已经读到了:

        

        

       

      

  • 相关阅读:
    R语言常用操作
    Java小知识点
    客户端(android,ios)与服务器通信
    图片保存数据库
    Centos 添加SWAP(交换分区)
    mysql基本知识
    php 工作模式
    apache 工作模式
    lnmp 虚拟主机配置及重写
    mysql alter的常用用法
  • 原文地址:https://www.cnblogs.com/fishperson/p/10520411.html
Copyright © 2011-2022 走看看