在storm群集上部署拓扑时出错
我试图在storm Clustre上部署一个简单的字数拓扑。我使用kafka作为输入（kafka Spout）。这是我得到的错误
java.lang.noClassDefFoundError：无法初始化类org.apache.log4j.log4jLogger.getLogger(logger.java:39)在kafka.utils.logging$class.logger(logger.scala:24)在kafka.consumer.simpleConsumer.logger$lzyCompute(SimpleConsumer.scala:30)在kafka.consumer.simpleConsumer.logger(SimpleConsumer.scala:30)在kafka.utils.logging$class.info(logging.scala:67)在kafka.consumer.simpleConsumer.info（SimpleConsumer.Scala：30）在kafka.consumer.SimpleConsumer.LiftedTree1$1（SimpleConsumer.Scala：74）在kafka.consumer.SimpleConsumer.Scala：68）在kafka.consumer.SimpleConsumer.Scala：127）在kafka.javaapi.consumer.SimpleConsumer.GetoffsetsBefore（SimpleConsumer.Scala：79）在storm.kafka.kafka.getoffset（Kafkautils.java:77）在storm.kafka.kafkautils.getoffset（kafkautils.java:67)位于storm.kafka.partitionmanager。（partitionmanager.java:83)位于storm.kafka.zkcoordinator.refresh（Zkcoordinator.java:98)在storm.kafka.zkcoordinator.getMyManagedPartitions(zkcoordinator.java:69)在storm.kafka.kafkaspout.nextTuple(kafkaspout.java:135)在backtype.storm.daemon.executor$fn__4654$fn__4669$fn__4698.invoke(executor.clj:565)在backtype.storm.util$async_loop$fn__458.invoke(util.clj:463)在clojure.lang.afn.run(afn.java:24)在java.lang.thread.run（thread.java：7 45）
共有1个答案
通过在我的storm库中添加log4j-over-SLF4j-1.6.6.jar解决了这个问题。
-
我是阿帕奇Storm的新手。我已经在intellij中用java创建了一个storm项目，它成功地创建了一个本地集群，并将拓扑提交给它，然后在本地运行。我想在亚马逊EC2上运行这个Storm项目。我跟踪了https://github.com/nathanmarz/storm-deploy/wiki链接。跟随链接成功发射了2个主管，1个动物园管理员和1个灵光。现在我想在服务器上运行我的拓扑。这是我在
-
我读了很多和Storm有关的网站。但我仍然无法将拓扑结构完美地映射到Storm集群中。 请帮助我理解这一点。 在Storm集群中有这样的术语 null null null 所有这些都要用Storm集群来映射。我已经在一个项目里工作了。所以我知道拓扑结构。
-
> 灵光升起 StormUI启动 我使用的两个工人都起来了 Zookeper已启动 我和暴风一起跑 Storm罐myjar.jar MyClass Nimbus提交拓扑 该拓扑的日志文件不会出现在workers中。 我在supervisor.log上的worker中有以下日志： 所以我确信我与nimbus有连接问题，但是worker中的属性文件是： 错误在哪里，我如何修复它？ 谢了！
-
Storm版本：1.2.2平台：Windows Server 2008 “错误：无法终止pid xxx进程，只能终止此进程（使用\f选项）。” 错误消息从以下图片翻译：error-info-pic 我不知道与这个错误，我已经使用谷歌搜索一些答案，但没有找到，所以我发送这条消息给你。我希望你能帮助我。 我已经编译了一个新的Storm-Core.jar，并在supervisor杀死worker时添加了
-
我终于觉得我有了一个在redis数据库上写的toopology。我有一个插销要打印，还有一个插销要插入Redis。但当我尝试启动拓扑时,会出现以下错误：
-
我正在尝试将storm/flux拓扑部署到远程服务器。拓扑已成功部署，但在服务器storm UI上，它显示“喷口滞后错误”： 无法获取Kafka的偏移滞后。理由：组织。阿帕奇。动物园管理员。KeeperException$NoNodeException:KeeperErrorCode=noode for/brokers/topics/blockdata/org上的分区。阿帕奇。动物园管理员。Kee