利用Trident topology实现预测疾病暴发的实例完整实例源码，具体详情参见博文：http://blog.csdn.net/l1028386804/article/details/79120204
2022-12-23 11:41:39
25.2MB
1
卡夫卡风暴
这是从Kafka中读取并在Elastic Search中建立索引的简单Apache Storm Trident拓扑。
##运行此Storm拓扑所需的设置### 1）Zookeeper。
Download from http://apache.osuosl.org/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
CD to zookeeper folder
$ cp conf/zoo_sample.cfg conf/zoo.cfg
$ bin/zkServer.sh start
### 2）卡夫卡。
Download from http://apache.mirrors.pair.com/kafka/0.8.2.0/kafka_2.10-0.8.2.0.tgz
CD to kafka folder
$ bin/kafka-
2022-04-16 11:39:13
9KB
1
整个项目主要实现了从模拟生成购物数据，到通过kafka传输数据，到通过storm的高级事务处理trident来进行实时流数据处理，最后，将实时生成的统计数据进行实时的可视化，生成类似天猫双十一实时数据大屏的可视化效果
2021-01-28 04:32:29
25.17MB
1