码迷,mamicode.com
首页 > Web开发 > 详细

flume-ng安装和简单使用例子

时间:2015-09-24 17:54:37      阅读:416      评论:0      收藏:0      [点我收藏+]

标签:

1.安装jdk。

2.下载解压flume,修改bin/netcat-memory-logger.conf,内容如下:

agent1.sources = sources1
agent1.channels = channels1 
agent1.sinks = sinks1
agent1.sources.sources1.type = netcat
agent1.sources.sources1.bind = localhost
agent1.sources.sources1.port = 44444
agent1.channels.channels1.type = memory
agent1.channels.channels1.capacity = 1000
agent1.channels.channels1.transactionCapacity = 100
agent1.sinks.sinks1.type = logger
agent1.sources.sources1.channels = channels1
agent1.sinks.sinks1.channel = channels1

3.启动flume-ng

bin/flume-ng agent --conf conf --conf-file bin/netcat-memory-logger.conf --name agent1 -Dflume.root.logger=INFO,console

4.然后再开一个 shell 终端窗口,telnet 上配置中侦听的端口,就可以发消息看到效果了,Flume 终端窗口此时会打印出信息,就表示成功了。

参考:

Flume NG 简介及配置实战

Flume(NG)架构设计要点及配置实践

 

 

 

 

 

flume-ng安装和简单使用例子

标签:

原文地址:http://my.oschina.net/cjun/blog/510704

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!