首页 > 代码库 > 2017.4.11 storm-kafka测试
2017.4.11 storm-kafka测试
测试storm-starter里的TridentWordCount,测试storm-kafka模块,单独建立工程,
注意log4j-slf4j-impl-2.1引起的依赖冲突,之前运行报错都是因为在storm安装包的lib库里已经有这个jar包了,
编译topology的时候又有其他依赖于这个jar包的工程把它打包进来了,从而引发冲突,从工程中去除这个依赖就好了。、
然后storm-kafka里的TridentWordCount运行成功。到这里kafka-storm-hbase全部打通,剩下整合的问题。
单独建立一个工程,是数据从kafka经storm最终存储到hbase成功,只是数据梳理过程不是业务所需要的。
2017.4.11 storm-kafka测试
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。