Kafka, mail # user - Re: connecting to kafkaserver and zk from inside VM - 2013-02-21, 03:48
 Search Hadoop and all its subprojects:

Switch to Threaded View
Copy link to this message
-
Re: connecting to kafkaserver and zk from inside VM
It might be related but my changes didn't do anything.

I have the server-properties attached.

Here is my timeout error:
Exception in thread "main"
org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to
zookeeper server within timeout: 4000
at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:876)
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:152)
at
kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:122)
at
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:65)
at
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:67)
at
kafka.consumer.Consumer$.createJavaConsumerConnector(ConsumerConnector.scala:88)
at
kafka.consumer.Consumer.createJavaConsumerConnector(ConsumerConnector.scala)
at consumer1.Consumer.<init>(Consumer.java:51)
at consumer1.NewConsumer.main(NewConsumer.java:16)
And also the:
[2013-02-20 19:41:13,196] INFO Accepted socket connection from /
192.168.190.188:49652 (org.apache.zookeeper.server.NIOServerCnxn)
[2013-02-20 19:41:13,197] WARN EndOfStreamException: Unable to read
additional data from client sessionid 0x0, likely client has closed socket
(org.apache.zookeeper.server.NIOServerCnxn)
[2013-02-20 19:41:13,197] INFO Closed socket connection for client /
192.168.190.188:49652 (no session established for client)
(org.apache.zookeeper.server.NIOServerCnxn)

I hope this helps to find the problem.

Thx,
Andre

On Tue, Feb 19, 2013 at 9:14 PM, Jun Rao <[EMAIL PROTECTED]> wrote:
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB