kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bateman, Matt" <mabate...@ebay.com>
Subject Quickstart Issue
Date Fri, 05 Aug 2011 00:37:47 GMT

This is a very basic question, hopefully I'm not wasting too much of anyone's time.

I have kafka and zookeeper running on one machine. I've written a very simple producer client
(in Java) that works fine when run from the same machine on which kafka and zookeeper are
running. However, if I run the simple client I wrote on a different machine, I'm not able
to send any messages. The relevant log section is at the end of this mail.

Do I need to run something else on the machine where I'm trying to run the client? The attempt
to connect to seems suspect to me. I've specified zk.connect as "".

Thanks for your time.

[2011-08-04 14:40:25,354] INFO Initiating client connection, connectString=
sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@cdfc9c (org.apache.zookeeper.ZooKeeper)
[2011-08-04 14:40:25,379] INFO Opening socket connection to server / (org.apache.zookeeper.ClientCnxn)
[2011-08-04 14:40:29,882] INFO Socket connection established to,
initiating session (org.apache.zookeeper.ClientCnxn)
[2011-08-04 14:40:29,912] INFO Session establishment complete on server,
sessionid = 0x13195dd1d200007, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn)
[2011-08-04 14:40:29,914] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
[2011-08-04 14:40:30,031] INFO Creating sync producer for broker id = 0 at
[2011-08-04 14:40:31,088] ERROR Connection attempt failed, next attempt in 1 ms (kafka.producer.SyncProducer)
java.net.ConnectException: Connection refused: connect
                at sun.nio.ch.Net.connect(Native Method)
                at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)
                at kafka.producer.SyncProducer.connect(SyncProducer.scala:171)
                at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:193)
                at kafka.producer.SyncProducer.send(SyncProducer.scala:84)
                at kafka.producer.SyncProducer.send(SyncProducer.scala:116)
                at kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:123)
                at kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:110)
                at kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:110)
                at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
                at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
                at kafka.producer.ProducerPool.send(ProducerPool.scala:110)
                at kafka.producer.Producer.send(Producer.scala:132)
                at kafka.javaapi.producer.Producer.send(Producer.scala:101)
                at Producer.perform(Producer.java:28)
                at harness.Harness.run(Harness.java:37)
                at java.lang.Thread.run(Unknown Source)
[2011-08-04 14:40:31,091] INFO Disconnecting from (kafka.producer.SyncProducer)
[2011-08-04 14:40:31,094] INFO Closing all sync producers (kafka.producer.ProducerPool)

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message