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

如果出现上面两个图片信息,表示运行成功。

最新文章

  1. ASP.NET MVC HtmlHelper之Html.ActionLink
  2. mysql,SQL标准,多表查询中内连接,外连接,自然连接等详解之查询结果集的笛卡尔积的演化
  3. 4.7---最近公共祖先(CC150)
  4. SlidingMenu实现app侧滑功能
  5. java代码实现rabbitMQ请求
  6. IIS服务器设置造成引用第三方权限不足问题
  7. 区别typedef和#define
  8. js 判断时间,满足执行框架
  9. [转] doxygen使用总结
  10. iOS真机测试种可能遇到的问题
  11. #include <locale.h> #include <locale>
  12. day10_python学习笔记_chapter13_面向对象编程
  13. HDU 4869 Turn the pokers(推理)
  14. Java新手入门的30个基本概念
  15. LEK-Introduction-Installation-Usage-new
  16. JavaWeb(九)AJAX
  17. java----微服务架构
  18. lamp源码安装
  19. 【BZOJ4591】[SHOI2015]超能粒子炮·改 (卢卡斯定理)
  20. python glob 模块

热门文章

  1. LeetCode—Unique Paths
  2. Golang&Python测试thrift
  3. HTTP API 设计指南(转)
  4. 完全用nosql轻松打造千万级数据量的微博系统
  5. SpringBoot与Mybatis整合实例详解
  6. 013-HQL中级3-Hive四种数据导入方式介绍
  7. CanvasRenderingContext2D.lineDashOffset
  8. SIP UserAgent (B2BUA client)——pjsip
  9. XDU 1037 倍流畅序列(字符串匹配+贪心)
  10. Visual studio插件 Reshaper--- 常用快捷键