Chinaunix首页 | 论坛 | 博客
  • 博客访问: 2194690
  • 博文数量: 866
  • 博客积分: 14125
  • 博客等级: 上将
  • 技术积分: 10638
  • 用 户 组: 普通用户
  • 注册时间: 2007-07-27 16:53
个人简介

https://github.com/landuochong

文章分类

全部博文(866)

文章存档

2019年(3)

2018年(1)

2017年(10)

2015年(3)

2014年(8)

2013年(3)

2012年(70)

2011年(103)

2010年(360)

2009年(283)

2008年(22)

分类: 大数据

2017-09-13 09:48:44

Flume收集数据到Kafka
1.启动Zookeeper, Kafka,参考上一篇文章,创建topic,启动Kafka消费者终端
2.修改Flume的配置文件

    MyAgent.sinks.mysink.type = org.apache.flume.sink.kafka.KafkaSink  
    MyAgent.sinks.mysink.topic = test  
    MyAgent.sinks.mysink.brokerList = localhost:9092  
    MyAgent.sinks.mysink.requiredAcks = 1  
    MyAgent.sinks.mysink.batchSize = 20 

3.启动Flume收集数据
阅读(811) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~
评论热议
请登录后评论。

登录 注册