Zookeeper create nothing when startup, you have to create your partitions in kafka broker.
bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic click_history --replication-factor 1 --partitions 10 2015-05-21 8:58 GMT-03:00 Benjamin Cuthbert <[email protected]>: > All, > > We changed or paths in zookeeper and we are now seeing > > java.lang.RuntimeException: java.lang.RuntimeException: > org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = > NoNode for /brokers/topics/warehouse_prices/partitions > at storm.kafka.DynamicBrokersReader.getBrokerInfo( > DynamicBrokersReader.java:81) ~[storm-kafka-0.9.4.jar:0.9.4] > at storm.kafka.trident.ZkBrokerReader.<init>(ZkBrokerReader.java:42) > ~[storm-kafka-0.9.4.jar:0.9.4] > at storm.kafka.KafkaUtils.makeBrokerReader(KafkaUtils.java:57) > ~[storm-kafka-0.9.4.jar:0.9.4] > at storm.kafka.KafkaSpout.open(KafkaSpout.java:87) > ~[storm-kafka-0.9.4.jar:0.9.4] > at > backtype.storm.daemon.executor$fn__3371$fn__3386.invoke(executor.clj:522) > ~[storm-core-0.9.4.jar:0.9.4] > at backtype.storm.util$async_loop$fn__460.invoke(util.clj:461) > ~[storm-core-0.9.4.jar:0.9.4] > at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na] > at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51] > > Should this not be discovered by the Spout on startup? >
