`
善良的java
  • 浏览: 16245 次
社区版块
存档分类
最新评论

flume NG 配置及案例

 
阅读更多
Flume 的一些核心概念:
组件功能
Agent使用JVM 运行Flume。每台机器运行一个agent,但是可以在一个agent中包含多个sources和sinks。
Client生产数据,运行在一个独立的线程。
Source从Client收集数据,传递给Channel。
Sink从Channel收集数据,运行在一个独立线程。
Channel连接 sources 和 sinks ,这个有点像一个队列。
Events可以是日志记录、 avro 对象等。


a1.sinkgroups.g1.processor.type = LOAD_BALANCE  负载均衡
a1.sinkgroups.g1.processor.selector = ROUND_ROBIN  轮循输出
a1.sinkgroups.g1.processor.backoff = true
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics