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
