Re: SpoutConfig zkRoot argument causing KafkaSpout exception
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 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 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 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 default client port set (i.e. 2181), whereas the >> brokers path is default as well. >> >> I supply SpoutConfig with the following arguments: >> >> *SpoutConfig spoutConfig = new SpoutConfig(hosts, "bytes", "/", "bytes" + >> UUID.randomUUID().toString());* >> >> However, obviously the problem seems to be in the zkRoot argument I’ve >> suplied SpoutConfig with. >> >> What value should it actually be? What does the zkRoot argument refer to? >> >> Thanks in advance! >> >
Re: SpoutConfig zkRoot argument causing KafkaSpout exception
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 > 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 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 default client port set (i.e. 2181), whereas the brokers >> path is default as well. >> >> I supply SpoutConfig with the following arguments: >> >> SpoutConfig spoutConfig = new SpoutConfig(hosts, "bytes", "/", "bytes" + >> UUID.randomUUID().toString()); >> >> However, obviously the problem seems to be in the zkRoot argument I’ve >> suplied SpoutConfig with. >> >> What value should it actually be? What does the zkRoot argument refer to? >> >> Thanks in advance!
Re: SpoutConfig zkRoot argument causing KafkaSpout exception
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 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 default client port set (i.e. 2181), whereas the brokers > path is default as well. > > I supply SpoutConfig with the following arguments: > > *SpoutConfig spoutConfig = new SpoutConfig(hosts, "bytes", "/", "bytes" + > UUID.randomUUID().toString());* > > However, obviously the problem seems to be in the zkRoot argument I’ve > suplied SpoutConfig with. > > What value should it actually be? What does the zkRoot argument refer to? > > Thanks in advance! >