2017.4.11 storm-kafka测试

Posted 2020-09-10

测试storm-starter里的TridentWordCount，测试storm-kafka模块，单独建立工程，

注意log4j-slf4j-impl-2.1引起的依赖冲突，之前运行报错都是因为在storm安装包的lib库里已经有这个jar包了，

编译topology的时候又有其他依赖于这个jar包的工程把它打包进来了，从而引发冲突，从工程中去除这个依赖就好了。、

然后storm-kafka里的TridentWordCount运行成功。到这里kafka-storm-hbase全部打通，剩下整合的问题。

单独建立一个工程，是数据从kafka经storm最终存储到hbase成功，只是数据梳理过程不是业务所需要的。