[置顶] STORM入门之(Flume Kafka集成架构)
2017-08-25 17:01
477 查看
Flume
Flume作用:收集日志组件下载地址:http://archive.apache.org/dist/flume/1.6.0/
版本:1.6.0以上集成Kafka
Flume配置
a1.sources = r1 a1.sinks = k1 a1.channels = c1 a1.sources.r1.type = syslogudp a1.sources.r1.port = 514 a1.sources.r1.host = 0.0.0.0 a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink a1.sinks.k1.brokerList=10.2.4.12:9092,10.2.4.13:9092,10.2.4.14:9092 a1.sinks.k1.topic=test_rce_yjd a1.sinks.k1.batchSize=20 a1.channels.c1.type = memory a1.channels.c1.capacity = 10000 a1.channels.c1.transactionCapacity = 10000 a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1
启动命令
/flume/apache-flume-1.6.0-bin/bin/flume-ng agent --conf conf --conf-file /flume/apache-flume-1.6.0-bin/conf/syslog.conf --name a1 -Dflume.root.logger=INFO,console
Kafka
Kafka作用:缓存日志监听是否发送至集群中
(1)shell 传送门:http://blog.csdn.net/yl3395017/article/details/73650250
(2)消费 传送门:http://blog.csdn.net/yl3395017/article/details/77547881
Storm
Strom作用:流式处理(1)消费Kafka集群信息 传送门:http://blog.csdn.net/yl3395017/article/details/77477716
效果
相关文章推荐
- [置顶] STORM入门之(TridentTopology集成Kafka)
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- flume+kafka+storm+mysql架构设计
- Flume+Kafka+Storm+Redis实时分析系统基本架构
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- STORM入门之(集成KafkaBolt)
- Flume+Kafka+Storm+Redis实时分析系统基本架构
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- Flume+Kafka+Storm+Redis实时分析系统基本架构
- Flume+Kafka+Storm+Redis实时分析系统基本架构
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- Flume+Kafka+Storm+Redis实时分析系统基本架构
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- [置顶] STORM入门之(集成HDFS)
- 分布式消息中间件(四)——Flume+Kafka+Storm+Redis生态架构实战
- 转:大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- 大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
- 大数据架构开发 挖掘分析 Hadoop HBase Hive Storm Spark Flume ZooKeeper Kafka Redis MongoDB Java 机器学习 云计算 视频教程