当前位置: 首页 > news >正文

flume 简单实例

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

1、配置

#example.conf:单节点Flume配置
    #命名Agent a1的组件
    a1.sources  =  r1
    a1.sinks  =  k1
    a1.channels  =  c1
 
    #描述/配置Source
    a1.sources.r1.type  =  netcat
    a1.sources.r1.bind  =  0.0.0.0
    a1.sources.r1.port  =  44444
 
    #描述Sink
    a1.sinks.k1.type  =  logger
 
    #描述内存Channel
    a1.channels.c1.type  =  memory
    a1.channels.c1.capacity  =  1000
    a1.channels.c1.transactionCapacity  =  100
 
    #为Channle绑定Source和Sink
    a1.sources.r1.channels  =  c1
    a1.sinks.k1.channel  =  c1

2、启动

135534_o7nw_3247419.png

bin/flume-ng agent --conf conf --conf-file conf/http.conf --name http -Dflume.root.logger=INFO,console
nohup bin/flume-ng agent --conf conf --conf-file conf/test.conf --name a1 >flume.log &
 

 

3、telnet 

4、flume 收到消息

 

转载于:https://my.oschina.net/u/3247419/blog/1031161

相关文章:

  • DirectX11 学习笔记10 - 用文件存储顶点布局
  • 深入浅出TensorFlow(六)TensorFlow高层封装
  • 今日小程序推荐:码农老黄历-看今天哪个方位BUG最少
  • Tomcat 80端口被占用
  • Mac_mac下使用ll等指令
  • Android M Launcher3主流程源码浅析
  • [iOS]Core Data浅析一 -- 启用Core Data
  • “量子密钥”:互联网信息安全“黑科技”
  • 俄黑客曝光第三批“禁药豁免”名单 不乏奥运金牌运动员
  • FB双倍押注Messenger应用:转型为购物娱乐中心
  • 奥巴马政府发布最新Fintech白皮书,提出十大创新监管原则
  • Google AI子公司采用区块链技术来跟踪英国的健康数据
  • 手机视频监控系统在智能家居中的应用
  • 缺陷上报统一模板及缺陷管理流程
  • 免费的OA系统,企业了解之后还敢用吗?
  • AWS实战 - 利用IAM对S3做访问控制
  • redis学习笔记(三):列表、集合、有序集合
  • vue:响应原理
  • weex踩坑之旅第一弹 ~ 搭建具有入口文件的weex脚手架
  • Yii源码解读-服务定位器(Service Locator)
  • 初探 Vue 生命周期和钩子函数
  • 高性能JavaScript阅读简记(三)
  • 技术发展面试
  • 买一台 iPhone X,还是创建一家未来的独角兽?
  • 面试题:给你个id,去拿到name,多叉树遍历
  • 腾讯视频格式如何转换成mp4 将下载的qlv文件转换成mp4的方法
  • 吴恩达Deep Learning课程练习题参考答案——R语言版
  • LevelDB 入门 —— 全面了解 LevelDB 的功能特性
  • #我与Java虚拟机的故事#连载06:收获颇多的经典之作
  • #在 README.md 中生成项目目录结构
  • (12)Hive调优——count distinct去重优化
  • (二)fiber的基本认识
  • (附源码)node.js知识分享网站 毕业设计 202038
  • (附源码)ssm户外用品商城 毕业设计 112346
  • (转)3D模板阴影原理
  • (转)chrome浏览器收藏夹(书签)的导出与导入
  • (转)eclipse内存溢出设置 -Xms212m -Xmx804m -XX:PermSize=250M -XX:MaxPermSize=356m
  • (转)shell中括号的特殊用法 linux if多条件判断
  • ***测试-HTTP方法
  • ./indexer: error while loading shared libraries: libmysqlclient.so.18: cannot open shared object fil
  • .NET Framework Client Profile - a Subset of the .NET Framework Redistribution
  • .net oracle 连接超时_Mysql连接数据库异常汇总【必收藏】
  • .NET 使用 ILMerge 合并多个程序集,避免引入额外的依赖
  • .NET 自定义中间件 判断是否存在 AllowAnonymousAttribute 特性 来判断是否需要身份验证
  • .Net接口调试与案例
  • .NET命令行(CLI)常用命令
  • .NET是什么
  • .Net通用分页类(存储过程分页版,可以选择页码的显示样式,且有中英选择)
  • .Net下的签名与混淆
  • [android] 手机卫士黑名单功能(ListView优化)
  • [C# WPF] 如何给控件添加边框(Border)?
  • [C#]C# OpenVINO部署yolov8图像分类模型
  • [C/C++]数据结构 深入挖掘环形链表问题
  • [Django 0-1] Core.Checks 模块
  • [Go WebSocket] 多房间的聊天室(三)自动清理无人房间