Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - connecting to kafkaserver and zk from inside VM


Copy link to this message
-
Re: connecting to kafkaserver and zk from inside VM
Andre Z 2013-02-21, 03:48
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:

> Is this related to item #2 in http://kafka.apache.org/faq.html ?
>
> Thanks,
>
> Jun
>
> On Tue, Feb 19, 2013 at 5:32 PM, Andre Z <[EMAIL PROTECTED]> wrote:
>
> > Hi,
> >
> > I have the following situation. I have set up a http post client sending
> > data to my VM. The VM has a post ressource that passes on the data to a
> > kafkaProducer.
> >
> > Everything works fine with having the kafkaConsumer inside the VM. Now I
> > want the cosumer outside and I get a timeout.
> >
> > I only changed the IP in the property file to the IP of my VM and I
> thought
> > it should work like it does with post.
> >
> >
> > Any thoughts?
> >
> >
> > Thanks,
> > Andre
> >
>