标签:kafka wordcount log imp 打包 orm hbase count art
测试storm-starter里的TridentWordCount,测试storm-kafka模块,单独建立工程,
注意log4j-slf4j-impl-2.1引起的依赖冲突,之前运行报错都是因为在storm安装包的lib库里已经有这个jar包了,
编译topology的时候又有其他依赖于这个jar包的工程把它打包进来了,从而引发冲突,从工程中去除这个依赖就好了。、
然后storm-kafka里的TridentWordCount运行成功。到这里kafka-storm-hbase全部打通,剩下整合的问题。
单独建立一个工程,是数据从kafka经storm最终存储到hbase成功,只是数据梳理过程不是业务所需要的。
标签:kafka wordcount log imp 打包 orm hbase count art
原文地址:http://www.cnblogs.com/cenglinjinran/p/6701540.html