Ok, I could make the example work.
The problem was that on the wiki page, there was no value for
"zk.connectiontimeout.ms".I inserted a value for that property (value = 100000)
and the example worked.
Also, I realized my mail client messed up the earlier message.
Here's the URL for the wiki page I was referring to -
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
From: Jayesh Thakrar <j_thak...@yahoo.com.INVALID>
To: "users@kafka.apache.org" <users@kafka.apache.org>
Sent: Tuesday, January 6, 2015 11:09 AM
Subject: Zookeeper Connection When Using High Level Sample Consumer Code from
Wiki
When I try running the Java Consumer example at
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+ExampleI get
the following zookeeper connection error.
I have verified zookeeper connectivity using a variety fo means (using
Zookeeper built-in client, sending 4-letter commands to the zk port, etc.) - so
I know the zookeeper info is correct.
Here's the error I get. Any pointers will be greatly appreciated.
Exception in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException:
Unable to connect to zookeeper server within timeout: 400 at
org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:880) at
org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98) at
org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84) at
kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:170)
at
kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:126)
at
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:66)
at
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:69)
at
kafka.consumer.Consumer$.createJavaConsumerConnector(ConsumerConnector.scala:100)
at
kafka.consumer.Consumer.createJavaConsumerConnector(ConsumerConnector.scala) at
kafka_sample.Consumer.<init>(Consumer.java:21) at
kafka_sample.Consumer.main(Consumer.java:71)
