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 > >
