Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@kafka.apache.org
Date: Sat, 15 Nov 2014 18:13:34 +0000 (UTC)
From: "Ashish Kumar Singh (JIRA)" <jira@apache.org>
To: dev@kafka.apache.org
Message-ID: <JIRA.12745375.1412203063000.509292.1416075214037@Atlassian.JIRA>
In-Reply-To: <JIRA.12745375.1412203063000@Atlassian.JIRA>
References: <JIRA.12745375.1412203063000@Atlassian.JIRA>
 <JIRA.12745375.1412203063260@arcas>
Subject: [jira] [Commented] (KAFKA-1664) Kafka does not properly parse
 multiple ZK nodes with non-root chroot
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


    [ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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)