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 条评论
回复 删除
下一页
