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
Neha Narkhede 2013-02-21, 04:43
It doesn't seem like your consumer box has access to the zookeeper box.
Have you tried telnetting to the zookeeper host/port ? I suspect that will
fail as well.

Thanks,
Neha
On Wed, Feb 20, 2013 at 7:48 PM, Andre Z <[EMAIL PROTECTED]> wrote:

> 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
> > >
> >
>