無法使用strom集羣從kafka讀取

Question

我正在運行Strom集羣，其中2個主管和1個nimbus正在運行。我在哪裏閱讀主題爲「topic1」的kafka。但在UI上，我得到的錯誤如下

java.lang.RuntimeException：java.lang.RuntimeException：org.apache.zookeeper.KeeperException $ NoNodeException：KeeperErrorCode = NoNode for/brokers/topics/topic1/partitions at storm.kafka .DynamicBrok

和工人_ *。日誌顯示以下錯誤。

java.io.FileNotFoundException：文件 '/app/storm/supervisor/stormdist/airpushTop-1-1431081661/stormconf.ser' 不存在 在org.apache.commons.io.FileUtils.openInputStream（文件實用程序。 java：299）〜[commons-io-2.4.jar：2.4] at org.apache.commons.io.FileUtils.readFileToByteArray（FileUtils.java:1763）〜[commons-io-2.4.jar：2.4] at backtype.storm.config $ read_supervisor_storm_conf.invoke（config.clj：212）〜[storm-core-0.9.4.jar：0.9.4] at backtype.storm.daemon.worker $ worker_data.invoke（worker.clj： 182）〜[storm-core-0.9.4.jar：0.9.4] at backtype.storm.daemon.worker $ fn__5033 $ exec_fn__1754__auto ____ 5034.invoke（worker.clj：398）〜[storm-core-0.9.4。 jar：0.9.4] at clojure.lang.AFn.applyToH elper（AFn.java:185）[clojure-1.5.1.jar：na] at clojure.lang.AFn.applyTo（AFn.java:151）[clojure-1.5.1.jar：na] at clojure。核心$ apply.invoke（core.clj：617）〜[clojure-1.5.1.jar：na] at backtype.storm.daemon.worker $ fn__5033 $ mk_worker__5089.doInvoke（worker.clj：389）[storm-core -0.9.4.jar：0.9.4] at backjure.lang.RestFn.invoke（RestFn.java:512）[clojure-1.5.1.jar：na] at backtype.storm.daemon.worker $ _main。 invoke（worker.clj：500）[storm-core-0.9.4.jar：0.9.4] at clojure.lang.AFn.applyToHelper（AFn.java:172）[clojure-1.5.1.jar：na] at clojure.lang.AFn.applyTo（AFn.java:151）[clojure-1.5.1.jar：na] at backtype.storm.daemon.worker.main（Unknown Source）[storm-core-0.9.4 .jar：0.9.4] 2015-05-08T17：09：19.209 + 0530 bs .util [ERROR]暫停過程：（「初始化時出錯」） java.lang.RuntimeException：（「初始化時出錯」） at backtype.storm.util $ exit_process_BANG_.doInvoke（util.clj：325）[storm- core-0.9.4.jar：0.9.4] at clojure.lang.RestFn.invoke（RestFn.java:423）[clojure-1.5.1.jar：na] at backtype.storm.daemon.worker $ fn__5033 $ mk_worker__5089.doInvoke（worker.clj：389）[storm-core-0.9.4.jar：0.9.4] at clojure.lang.RestFn.invoke（RestFn.java:512）[clojure-1.5.1.jar ：na] at backtype.storm.daemon.worker $ _main.invoke（worker.clj：500）[storm-core-0.9.4.jar：0.9.4] at clojure.lang.AFn.applyToHelper（AFn。 java：172）[clojure-1.5.1.jar：na] at clojure.lang.AFn.applyTo（AFn.java:151）[clojure-1.5.1.jar：na] ava.lang.R unnyException：java.lang.RuntimeException：org.apache.zookeeper.KeeperException $ NoNodeException：KeeperErrorCode = NoNode for/brokers/topics/topic1/partitions at storm.kafka.DynamicBrokt backtype.storm.daemon.worker.main（Unknown Source）[ storm-core-0.9.4.jar：0.9.4]

我使用的是kafka_2.11-0.8.2.1，apache-storm-0.9.4和zookeeper-3.4.6。

kafka和cluster中沒有不匹配的zookeeper jar版本。

請幫我這裏。

非常感謝提前。

Answer 1

您是否確定了kafka中的topic1，並且您可以使用控制檯使用者從中讀取它，我已經看過org.apache.zookeeper。KeeperException $ NoNodeException：KeeperErrorCode = NoNode for ...當部署風暴拓撲時該主題不存在時。

你也可以發佈一些關於如何配置卡夫卡噴嘴的代碼？

這個錯誤是零星的還是一致的？