Thanks for the help. I get the same NoNode exception no matter what zkRoot and id are set to. I chose to use "" as zkRoot because that would rule out the possibility that the parent node (the zkRoot node) wasn't created yet, which would lead to a valid NoNode exception.
I also find I get the same NoNode exception when I try to run this <https://github.com/wurstmeister/storm-kafka-0.8-plus-test> Storm spout test (storm-kafka-0.8-plus-test). Here's <http://pastebin.com/raw/tbfaVhY6> a pastebin of the exact error message. So I suspect that the problem lies in my zookeeper installation, or in a Java lib around it. But the zookeeper shell works fine, and I'm using the same zookeeper code that came with Kafka, so I'm at a loss as to what exactly could be the problem. Any further help is appreciated. On Thu, Jan 14, 2016 at 12:31 PM Milind Vaidya <[email protected]> wrote: > Try > > SpoutConfig conf = new SpoutConfig(hosts, topicName, "/event_spout", > "event_spout"); > > You had given empty string in the conf, parameter zkRoot seems missing. > > > > > On Wed, Jan 13, 2016 at 4:46 PM, Jamie W <[email protected]> wrote: > >> Hi, >> >> I'm having troubles using KafkaSpout in storm-kafka. It can connect to >> zookeeper, but it throws a NoNode exception when trying to write the offset >> ZNode. >> >> Here's my setup conf: >> >> String topicName = "events"; >> BrokerHosts hosts = new ZkHosts("localhost:2181"); >> SpoutConfig conf = new SpoutConfig(hosts, topicName, "", "event_spout"); >> conf.scheme = new EventMultiScheme(); >> >> So it tries to write to /event_spout. Here's the error it gets: >> >> 15172 [ProcessThread(sid:0 cport:-1):] INFO >> o.a.s.s.o.a.z.s.PrepRequestProcessor - Got user-level KeeperException when >> processing sessionid:0x1523d43b964001c type:create cxid:0x3 zxid:0x57 >> txntype:-1 reqpath:n/a Error Path:/event_spout Error:KeeperErrorCode = >> NoNode for /event_spout >> >> The zookeeper docs >> <https://zookeeper.apache.org/doc/r3.3.2/api/org/apache/zookeeper/ZooKeeper.html> >> say: >> >> If the parent node does not exist in the ZooKeeper, a KeeperException >> with error code KeeperException.NoNode will be thrown. >> >> >> But this can't be the case because the parent node of /event_spout is >> just /, and / has to exist. What am I doing wrong? >> >> Things I've also tried: >> - Manually creating the node in the zookeeper shell >> - Using different values for the zkRoot and id >> >> Zookeeper version - Zookeeper version: 3.4.6-1569965, >> Storm version - commit 4c56eb7e47a723ec870c5783d68d8320381e2dff >> >> Thanks, >> Jamie >> >> >
