首页 > 代码库 > 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测试