怎么错的呢。以为是Kafka broker挂了，又重启Kafka，不管用，又是重启storm集群，也不行，一遍debug一遍百度，最后发现是代码问题，集群模式和本地模式的执行方法是不一样的(丢人呐)，如下。
这个pom文件的这里也得注释掉！
相关文章：
相似解决方案
热门标签
怎么错的呢。以为是Kafka broker挂了，又重启Kafka，不管用，又是重启storm集群，也不行，一遍debug一遍百度，最后发现是代码问题，集群模式和本地模式的执行方法是不一样的(丢人呐)，如下。
这个pom文件的这里也得注释掉！
相关文章：