Apache storm项目
2018-12-10 14:08:45 1 举报
stormspout使用kafka做数据源,flume做日志管理,对消费记录的处理流程
作者其他创作
大纲/内容
实时订单日志
在该项目中使用TransactionalTridentKafkaSpout对消息进行实时分析
HBASE集群(HBASE 2.0.1)
zookeeper 集群(Apache zookeeper3.4.8 )
1、使用flume从订单服务上拉取订单日志,并存储在分布式高吞吐消息系统kafka中
kafka集群(Apache kafka2.11)
3、将处理后的结果存放到HBASE数据库中
storm集群(Apache storm1.1.0)
2、从kafka中读取日志消息并进入到storm系统中进行实时分析,同时使用zookeeper管理storm对kafka中的消息的消费记录。
订单服务器(log4j2)
收藏
0 条评论
下一页