flume-扇入


给另外两台机器发送flume文件夹

[root@hadoop01 src]# scp -r flume/ root@hadoop02:/usr/local/src
[root@hadoop01 src]# scp -r flume/ root@hadoop03:/usr/local/src

hadoop01


a1.sources  =  r1
a1.sinks  =  k1
a1.channels  =  c1

a1.sources.r1.type  = http
a1.sources.r1.bind = 0.0.0.0
a1.sources.r1.port = 22222 

a1.sinks.k1.type  =  avro
a1.sinks.hostname = hadoop03
a1.sinks.k1.port = 22222

a1.channels.c1.type  =  memory
a1.channels.c1.capacity  =  1000
a1.channels.c1.transactionCapacity  =  100

a1.sources.r1.channels  =  c1
a1.sinks.k1.channel  =  c1

hadoop02


a1.sources  =  r1
a1.sinks  =  k1
a1.channels  =  c1

a1.sources.r1.type  =  http
a1.sources.r1.bind = 0.0.0.0
a1.sources.r1.port = 22222 

a1.sinks.k1.type  =  avro
a1.sinks.hostname = hadoop03
a1.sinks.k1.port = 22222

a1.channels.c1.type  =  memory
a1.channels.c1.capacity  =  1000
a1.channels.c1.transactionCapacity  =  100

a1.sources.r1.channels  =  c1
a1.sinks.k1.channel  =  c1

hadoop03

a1.sources  =  r1
a1.sinks  =  k1
a1.channels  =  c1

a1.sources.r1.type  =  avro
a1.sources.r1.bind = 0.0.0.0
a1.sources.r1.port = 22222 

a1.sinks.k1.type  =  logger

a1.channels.c1.type  =  memory
a1.channels.c1.capacity  =  1000
a1.channels.c1.transactionCapacity  =  100

a1.sources.r1.channels  =  c1
a1.sinks.k1.channel  =  c1
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • Hadoop HA集群搭建文档.............................................
    钟敏_1788阅读 1,626评论 0 0
  • 博客原文 翻译作品,水平有限,如有错误,烦请留言指正。原文请见 官网英文文档 引言 概述 Apache Flume...
    rabbitGYK阅读 11,744评论 13 34
  • Flume 日志收集系统 #安装 在node01下 在hadoop用户下 cd ~/apps 在此路径下 解压后是...
    快乐大数据阅读 679评论 0 0
  • 介绍 概述 Apache Flume是为有效收集聚合和移动大量来自不同源到中心数据存储而设计的可分布,可靠的,可用...
    ximengchj阅读 3,702评论 0 13
  • 一九九九年的六一儿童节江西省上饶市鄱阳县人民医院的产房里等来了又一个女孩的降生。是的又一个女孩,她并不讨喜。这家人...
    阿龄Alin阅读 216评论 0 0

友情链接更多精彩内容