[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-28 Thread Jun Rao (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14341660#comment-14341660
 ] 

Jun Rao commented on KAFKA-1664:


Thanks for the patch. The patch makes every create operation in ZK a bit more 
expensive since it has to do an extra exists check. This may slow down 
operations like creating a new topic, especially when there are lots of 
partitions.

The checking of the chroot really just needs to be done once at the beginning. 
I am thinking that one way to improve this is to make ZkPath a singleton. It 
will do the chroot check on first create and remembers the result. Subsequent 
create calls will just reuse the result.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish K Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, 
 KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch, 
 KAFKA-1664_2015-02-24_11:02:23.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Re: [jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-25 Thread Jonathan Creasy 
I think this is because it expects the string to be:

 baelish-001.edh.cloudera.com:2181,baelish-002.edh.cloudera.com:2181,baelis
h-003.edh.cloudera.com:2181/kafka


I don¹t think you would ever want to have a different root per host.

-Jonathan

On 2/24/15, 1:04 PM, Ashish Singh (JIRA) j...@apache.org wrote:


[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.p
lugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14335255#com
ment-14335255 ] 

Ashish Singh commented on KAFKA-1664:
-

[~nehanarkhede] addressed the warnings issue. Thanks for the review.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch,
KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch,
KAFKA-1664_2015-02-24_11:02:23.patch


 When using a non-root ZK directory for Kafka, if you specify multiple
ZK servers, Kafka does not seem to properly parse the connection string.
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper
baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181
/kafka,baelish-003.edh.cloudera.com:2181/kafka --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping
consumer:  (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
  at 
org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
  at 
org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
  at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
  at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
  at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
  at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
  at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
  at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
  at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
  at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
  at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
  at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
  at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
  at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
  at 
kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
  at 
kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils
.scala:306)
  at 
kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsume
rConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
  at 
kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(Z
ookeeperConsumerConnector.scala:755)
  at 
kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(Zo
okeeperConsumerConnector.scala:145)
  at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
  at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper
baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-25 Thread Jonathan Creasy (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14337379#comment-14337379
 ] 

Jonathan Creasy commented on KAFKA-1664:


I think this is because it expects the string to be:

baelish-001.edh.cloudera.com:2181,baelish-002.edh.cloudera.com:2181,baelis
h-003.edh.cloudera.com:2181/kafka


I don¹t think you would ever want to have a different root per host.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish K Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, 
 KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch, 
 KAFKA-1664_2015-02-24_11:02:23.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-25 Thread Jonathan Creasy (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14337382#comment-14337382
 ] 

Jonathan Creasy commented on KAFKA-1664:


nevermind, missed Jun's response farther up. Carry on! :)

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish K Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, 
 KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch, 
 KAFKA-1664_2015-02-24_11:02:23.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-24 Thread Neha Narkhede (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14335053#comment-14335053
 ] 

Neha Narkhede commented on KAFKA-1664:
--

[~ashishujjain] Thanks for the reminder. The patch looks good, the only comment 
I have is that it introduces a bunch of build warnings-
{code}
/Users/nnarkhed/Projects/kafka/core/src/test/scala/unit/kafka/zk/ZKPathTest.scala:45:
 This catches all Throwables. If this is really intended, use `case exception : 
Throwable` to clear this warning.
  case exception = fail(Should have thrown ConfigException)
{code}


 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, 
 KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-24 Thread Ashish Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14335248#comment-14335248
 ] 

Ashish Singh commented on KAFKA-1664:
-

Updated reviewboard https://reviews.apache.org/r/28108/
 against branch trunk

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, 
 KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch, 
 KAFKA-1664_2015-02-24_11:02:23.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-24 Thread Ashish Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14335255#comment-14335255
 ] 

Ashish Singh commented on KAFKA-1664:
-

[~nehanarkhede] addressed the warnings issue. Thanks for the review.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, 
 KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch, 
 KAFKA-1664_2015-02-24_11:02:23.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-02-23 Thread Ashish Kumar Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14334266#comment-14334266
 ] 

Ashish Kumar Singh commented on KAFKA-1664:
---

[~nehanarkhede] could you review this when you get a chance.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Kumar Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, 
 KAFKA-1664.patch, KAFKA-1664_2015-01-29_10:26:20.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-01-16 Thread Ashish Kumar Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14280988#comment-14280988
 ] 

Ashish Kumar Singh commented on KAFKA-1664:
---

Testing file 
[KAFKA-1664.2.patch|https://issues.apache.org/jira/secure/attachment/12686456/KAFKA-1664.2.patch]
 against branch trunk took 0:09:06.543433.

{color:red}Overall:{color} -1 due to 2 errors

{color:red}ERROR:{color} Some unit tests failed (report)
{color:red}ERROR:{color} Failed unit test: 
{{kafka.consumer.ZookeeperConsumerConnectorTest  testConsumerRebalanceListener 
FAILED
}}
{color:green}SUCCESS:{color} Gradle bootstrap was successful
{color:green}SUCCESS:{color} Clean was successful
{color:green}SUCCESS:{color} Patch applied correctly
{color:green}SUCCESS:{color} Patch add/modify test case
{color:green}SUCCESS:{color} Gradle bootstrap was successful
{color:green}SUCCESS:{color} Patch compiled

This message is automatically generated.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Kumar Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, KAFKA-1664.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2015-01-14 Thread Ashish Kumar Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14277439#comment-14277439
 ] 

Ashish Kumar Singh commented on KAFKA-1664:
---

Testing file 
[KAFKA-1664.2.patch|https://issues.apache.org/jira/secure/attachment/12686456/KAFKA-1664.2.patch]
 against branch trunk took 0:10:03.658955.

{color:red}Overall:{color} -1 due to 11 errors

{color:red}ERROR:{color} Some unit tests failed (report)
{color:red}ERROR:{color} Failed unit test: 
{{kafka.server.ServerGenerateBrokerIdTest  
testConsistentBrokerIdFromUserConfigAndMetaProps FAILED
}}
{color:red}ERROR:{color} Failed unit test: 
{{kafka.server.ServerGenerateBrokerIdTest  testMultipleLogDirsMetaProps FAILED
}}
{color:red}ERROR:{color} Failed unit test: {{kafka.server.ServerShutdownTest  
testCleanShutdownWithDeleteTopicEnabled FAILED
}}
{color:red}ERROR:{color} Failed unit test: 
{{kafka.server.ServerGenerateBrokerIdTest  testAutoGenerateBrokerId FAILED
}}
{color:red}ERROR:{color} Failed unit test: {{kafka.network.SocketServerTest  
testMaxConnectionsPerIp FAILED
}}
{color:red}ERROR:{color} Failed unit test: {{kafka.server.ServerShutdownTest  
testCleanShutdown FAILED
}}
{color:red}ERROR:{color} Failed unit test: {{kafka.network.SocketServerTest  
testMaxConnectionsPerIPOverrides FAILED
}}
{color:red}ERROR:{color} Failed unit test: 
{{kafka.server.ServerGenerateBrokerIdTest  testUserConfigAndGeneratedBrokerId 
FAILED
}}
{color:red}ERROR:{color} Failed unit test: {{kafka.server.ServerShutdownTest  
testCleanShutdownAfterFailedStartup FAILED
}}
{color:red}ERROR:{color} Failed unit test: 
{{kafka.consumer.ZookeeperConsumerConnectorTest  testConsumerRebalanceListener 
FAILED
}}
{color:green}SUCCESS:{color} Gradle bootstrap was successful
{color:green}SUCCESS:{color} Clean was successful
{color:green}SUCCESS:{color} Patch applied correctly
{color:green}SUCCESS:{color} Patch add/modify test case
{color:green}SUCCESS:{color} Gradle bootstrap was successful
{color:green}SUCCESS:{color} Patch compiled

This message is automatically generated.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Kumar Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, KAFKA-1664.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-12-29 Thread Ashish Kumar Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260500#comment-14260500
 ] 

Ashish Kumar Singh commented on KAFKA-1664:
---

[~nehanarkhede] still waiting for your review.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Kumar Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, KAFKA-1664.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-12-11 Thread Ashish Kumar Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14243024#comment-14243024
 ] 

Ashish Kumar Singh commented on KAFKA-1664:
---

[~nehanarkhede] Addressed your review comment. Kindly take a look.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Kumar Singh
Priority: Minor
  Labels: newbie
 Attachments: KAFKA-1664.1.patch, KAFKA-1664.2.patch, KAFKA-1664.patch


 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-11-16 Thread Gwen Shapira (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213899#comment-14213899
 ] 

Gwen Shapira commented on KAFKA-1664:
-

Here you go, [~singhashish]. Have fun.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Ashish Kumar Singh
Priority: Minor
  Labels: newbie

 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-11-15 Thread Ashish Kumar Singh (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14213707#comment-14213707
 ] 

Ashish Kumar Singh commented on KAFKA-1664:
---

[~gwenshap] I am thinking of taking a look at this. If it is OK with you, 
kindly assign the JIRA to me.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Gwen Shapira
Priority: Minor
  Labels: newbie

 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-10-02 Thread Ricky Saltzer (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14156889#comment-14156889
 ] 

Ricky Saltzer commented on KAFKA-1664:
--

[~junrao] my apologies, thanks for the recommendation, that *did* actually 
work. +1 for a more meaningful error. 

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Gwen Shapira
Priority: Blocker
  Labels: newbie

 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-10-02 Thread Gwen Shapira (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14157228#comment-14157228
 ] 

Gwen Shapira commented on KAFKA-1664:
-

For a more meaningful error, I'm thinking: Catch the exception thrown by 
zkClient at createParentPath, log an error like Invalid ZooKeeper path, please 
check syntax and that path exists and throw our own ConfigException

Since the original error is thrown by zkClient, we'll need to handle that in 
multiple places where we call it. Does it make sense to patch zkClient instead?



 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Gwen Shapira
Priority: Minor
  Labels: newbie

 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-10-01 Thread Jun Rao (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14155908#comment-14155908
 ] 

Jun Rao commented on KAFKA-1664:


Actually, namespace should only be included once in a ZK url, not after every 
host:port. So the correct ZK URL should be

 
baelish-001.edh.cloudera.com:2181,baelish-002.edh.cloudera.com:2181,baelish-003.edh.cloudera.com:2181/kafka

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Gwen Shapira
Priority: Blocker
  Labels: newbie

 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-10-01 Thread Ricky Saltzer (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14155951#comment-14155951
 ] 

Ricky Saltzer commented on KAFKA-1664:
--

Yes I've tried that as well, same problem.



 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Gwen Shapira
Priority: Blocker
  Labels: newbie

 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

2014-10-01 Thread Neha Narkhede (JIRA) 

[ 
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14156057#comment-14156057
 ] 

Neha Narkhede commented on KAFKA-1664:
--

+1 on providing a more meaningful error.

 Kafka does not properly parse multiple ZK nodes with non-root chroot
 

 Key: KAFKA-1664
 URL: https://issues.apache.org/jira/browse/KAFKA-1664
 Project: Kafka
  Issue Type: Bug
  Components: clients
Reporter: Ricky Saltzer
Assignee: Gwen Shapira
Priority: Blocker
  Labels: newbie

 When using a non-root ZK directory for Kafka, if you specify multiple ZK 
 servers, Kafka does not seem to properly parse the connection string. 
 *Error*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka,baelish-002.edh.cloudera.com:2181/kafka,baelish-003.edh.cloudera.com:2181/kafka
  --topic test-topic
 [2014-10-01 15:31:04,629] ERROR Error processing message, stopping consumer:  
 (kafka.consumer.ConsoleConsumer$)
 java.lang.IllegalArgumentException: Path length must be  0
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
   at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
   at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:766)
   at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
   at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
   at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
   at kafka.utils.ZkUtils$.createParentPath(ZkUtils.scala:245)
   at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:256)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:268)
   at 
 kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(ZkUtils.scala:306)
   at 
 kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(ZookeeperConsumerConnector.scala:226)
   at 
 kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.init(ZookeeperConsumerConnector.scala:755)
   at 
 kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:145)
   at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:196)
   at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala)
 {code}
 *Working*
 {code}
 [root@hodor-001 bin]# ./kafka-console-consumer.sh --zookeeper 
 baelish-001.edh.cloudera.com:2181/kafka --topic test-topic
 {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)