Re: SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Ambud Sharma
It will refer to the root, it uses a slash by default. As you can see you have 2 in the path: *"//bytes3b68b144-e13c-4de3-**beed**-405e3ca5ae20/partition_1"* On Sep 17, 2016 12:49 AM, "Dominik Safaric" wrote: > If the value is set to an empty string, to what path

Re: SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Dominik Safaric
If the value is set to an empty string, to what path does it actually refer to? Dominik > On 17 Sep 2016, at 09:40, Ambud Sharma wrote: > > Zkroot should be empty string not a /. > > Basically that config refers to the path where the consumer offsets will be >

Re: SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Ambud Sharma
Zkroot should be empty string not a /. Basically that config refers to the path where the consumer offsets will be stored. On Sep 17, 2016 12:20 AM, "Dominik Safaric" wrote: > Hi, > > I’ve set up a topology consisting of a Kafka spout. But unfortunately, I > keep

SpoutConfig zkRoot argument causing KafkaSpout exception

2016-09-17 Thread Dominik Safaric
Hi, I’ve set up a topology consisting of a Kafka spout. But unfortunately, I keep getting the exception Caused by: java.lang.IllegalArgumentException: Invalid path string "//bytes3b68b144-e13c-4de3-beed-405e3ca5ae20/partition_1" caused by empty node name specified @1. Zookeeper has the