分享web开发知识

注册/登录|最近发布|今日推荐

主页 IT知识网页技术软件开发前端开发代码编程运营维护技术分享教程案例
当前位置:首页 > 教程案例

简单模拟flume

发布时间:2023-09-06 02:35责任编辑:傅花花关键词:暂无标签

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

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

知识推荐

我的编程学习网——分享web前端后端开发技术知识。 垃圾信息处理邮箱 tousu563@163.com 网站地图
icp备案号 闽ICP备2023006418号-8 不良信息举报平台 互联网安全管理备案 Copyright 2023 www.wodecom.cn All Rights Reserved