-
Kafka 0.8.1.1与Storm 0.9.1的开发整合(亲自验证)
资源介绍
storm0.9.1+kafka0.8.1.1亲测可以跑起来的工程,有些乱,我后续继续整理
kafka0.8Storm0.9.1Optr/com.ks.topoloty.CounterTopology.java是启动主文件
Kafka0.8Optr2/SendMessage.java是测试文件
可以在kafka0.8Storm0.9.1Optr/com.ks.CounterBolt.java里面execute()看到输出
谁用谁知道,这个kafka+storm的整合处理起来比较麻烦,所以使用的时候耐心点。
- 上一篇: 第5章pandas入门.xmind
- 下一篇: Linux常用命令之文件处理.xmind