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