You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Dominik Safaric <do...@gmail.com> on 2016/09/17 07:20:34 UTC
SpoutConfig zkRoot argument causing KafkaSpout exception
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
Posted by Ambud Sharma <as...@gmail.com>.
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" <do...@gmail.com>
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 <as...@gmail.com> 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" <do...@gmail.com>
> 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
Posted by Dominik Safaric <do...@gmail.com>.
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 <as...@gmail.com> 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" <do...@gmail.com> 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
Posted by Ambud Sharma <as...@gmail.com>.
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" <do...@gmail.com>
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!
>