Hadoop实战-Flume之Source replicating(十四)
2024-10-20 05:33:43
a1.sources = r1
a1.sinks = k1 k2
a1.channels = c1 c2 # Describe/configure the source
a1.sources.r1.type = netcat
a1.sources.r1.bind = localhost
a1.sources.r1.port = 44444 # Describe the sink
a1.sinks.k1.type =file_roll
a1.sinks.k1.sink.directory=/home/chenyun/data/flume/file_sinke1 a1.sinks.k2.type =file_roll
a1.sinks.k2.sink.directory=/home/chenyun/data/flume/file_sinke2 # Use a channel which buffers events in memory
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100 a1.channels.c2.type = memory
a1.channels.c2.capacity = 1000
a1.channels.c2.transactionCapacity = 100 # Bind the source and sink to the channel
a1.sources.r1.channels = c1 c2
a1.sinks.k1.channel=c1
a1.sinks.k2.channel = c2
最新文章
- SharePoint 2013常用开发工具分享
- sql中的!=判断的注意事项
- abort 用法讨论
- A memory leak issue with WPF Command Binding
- bootstrap fileinput添加上传成功回调事件
- (原)String类两种实例化的区别
- 通过一段代码说明C#中rel与out的使用区别
- Python的方法分类
- KVC&;KVO&;NSNotification
- 根据body的内容 查找h2标签的@class=";subtitle";的值
- Hyperworks、Nastran、Abaqus与ansys的区别
- 原型----------prototype详细解答
- mac如何进入应用程序的内部文件夹?
- Gathering Initial Troubleshooting Information for Analysis of ORA-4031 Errors on the Shared Pool
- 记一次深度系统安装至windows系统盘提示挂载为只读模式问题
- 【1】【leetcode-33,81】 搜索旋转排序数组
- python二进制转换
- java.net.UnknownHostException: www.terracotta.org
- Design Principle
- [logic]逻辑整理
热门文章
- 单堆石子的Nim Game
- luogu P1616 疯狂的采药
- jzyzOJ 1658【bzoj1798改编】
- Inno Setup打包的安装程序在Vista/Win7上自动提示需要管理员权限的方法
- iOS github大全 &; iOS7的学习blog
- zabbix监控系统-部署规划
- xshell登录到CentOS7上时出现“The remote SSH server rejected X11 forwarding request.
- [置顶]
 个人微信号发送zabbix告警信息
- 如何DIY一个简单的反弹Shell脚本
- 使用assembly将maven项目pom.xml中的jar包打包