记一次storm启动报错。。

记一次storm启动报错。。
怎么错的呢。以为是Kafka broker挂了,又重启Kafka,不管用,又是重启storm集群,也不行,一遍debug一遍百度,最后发现是代码问题,集群模式和本地模式的执行方法是不一样的(丢人呐),如下。
记一次storm启动报错。。
这个pom文件的这里也得注释掉!
记一次storm启动报错。。