Flume实例一学习
2024-08-22 03:57:46
cp conf/flume-env.sh.template conf/flume-env.sh
打开flume-env.sh,配置Java环境变量
[root@test1 apache-flume-1.6.0-bin]# vim conf/flume.conf # Define a memory channel called ch1 on agent1
agent1.channels.ch1.type = memory # Define an Avro source called avro-source1 on agent1 and tell it
# to bind to 0.0.0.0:41414. Connect it to channel ch1.
agent1.sources.avro-source1.channels = ch1
agent1.sources.avro-source1.type = avro
agent1.sources.avro-source1.bind = 0.0.0.0
agent1.sources.avro-source1.port = 41414 # Define a logger sink that simply logs all events it receives
# and connect it to the other end of the same channel.
agent1.sinks.log-sink1.channel = ch1
agent1.sinks.log-sink1.type = logger # Finally, now that we've defined all of our components, tell
# agent1 which ones we want to activate.
agent1.channels = ch1
agent1.sources = avro-source1
agent1.sinks = log-sink1
bin/flume-ng avro-client --conf conf -H localhost -p 41414 -F /etc/passwd -Dflume.root.logger=DEBUG,console
bin/flume-ng avro-client --conf conf -H localhost -p 41414 -F /etc/passwd -Dflume.root.logger=DEBUG,console
如果出现上面两个图片信息,表示运行成功。
最新文章
- ASP.NET MVC HtmlHelper之Html.ActionLink
- mysql,SQL标准,多表查询中内连接,外连接,自然连接等详解之查询结果集的笛卡尔积的演化
- 4.7---最近公共祖先(CC150)
- SlidingMenu实现app侧滑功能
- java代码实现rabbitMQ请求
- IIS服务器设置造成引用第三方权限不足问题
- 区别typedef和#define
- js 判断时间,满足执行框架
- [转] doxygen使用总结
- iOS真机测试种可能遇到的问题
- #include <;locale.h>; #include <;locale>;
- day10_python学习笔记_chapter13_面向对象编程
- HDU 4869 Turn the pokers(推理)
- Java新手入门的30个基本概念
- LEK-Introduction-Installation-Usage-new
- JavaWeb(九)AJAX
- java----微服务架构
- lamp源码安装
- 【BZOJ4591】[SHOI2015]超能粒子炮&#183;改 (卢卡斯定理)
- python glob 模块
热门文章
- LeetCode—Unique Paths
- Golang&;Python测试thrift
- HTTP API 设计指南(转)
- 完全用nosql轻松打造千万级数据量的微博系统
- SpringBoot与Mybatis整合实例详解
- 013-HQL中级3-Hive四种数据导入方式介绍
- CanvasRenderingContext2D.lineDashOffset
- SIP UserAgent (B2BUA client)——pjsip
- XDU 1037 倍流畅序列(字符串匹配+贪心)
- Visual studio插件 Reshaper--- 常用快捷键