Re: SpoutConfig zkRoot argument causing KafkaSpout exception

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

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

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

SpoutConfig zkRoot argument causing KafkaSpout exception

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