Try telnet to the broker and the port directly see if you can make the connection. If not, it's very likely that the server is not bound to the ip/host that you want. See #2 in http://incubator.apache.org/kafka/faq.html
Thanks, Jun 2012/2/7 SuoNayi <suonayi2...@163.com> > Sorry for that I have found that hostname of the test server is of > misconfigure. > Here is new question when I send messages with 20 producers that each > workes in it's own thread, > > My client throws exception of timeout: > Exception in thread "Thread-2" java.net.ConnectException: Connection timed > out: connect > at sun.nio.ch.Net.connect(Native Method) > at sun.nio.ch.SocketChannelImpl.connect(Unknown Source) > at kafka.producer.SyncProducer.connect(SyncProducer.scala:172) > at kafka.producer.SyncProducer.send(SyncProducer.scala:101) > at kafka.producer.SyncProducer.send(SyncProducer.scala:117) > at > kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:116) > at > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102) > at > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102) > 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:102) > at kafka.producer.Producer.configSend(Producer.scala:167) > at kafka.producer.Producer.send(Producer.scala:106) > at kafka.javaapi.producer.Producer.send(Producer.scala:104) > at test.kafka.TestOutboundKfa$Sender.run(TestOutboundKfa.java:87) > > At 2012-02-07 10:26:43,SuoNayi <suonayi2...@163.com> wrote: > >Hi all, > > I'm new to kafka.I set up zooker server and kafka server on my test > server by following the quickstart. > > I also success running the example list in the quickstart,such as step > 3 and step 4. > > Now I set up a project on my pc to run examples of directory named > kafka-0.7.0-incubating-src\examples. > > Of course, I changed addresses and ports of zk server and kafka that > both pointed at my test server. > > When start the main function of class KafkaConsumerProducerDemo,it > throws the following exception: > >Exception in thread "main" > org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to > zookeeper server within timeout: 6000 > >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.producer.ZKBrokerPartitionInfo.<init>(ZKBrokerPartitionInfo.scala:63) > >at kafka.producer.Producer.<init>(Producer.scala:53) > >at kafka.javaapi.producer.Producer.<init>(Producer.scala:33) > >at kafka.javaapi.producer.Producer.<init>(Producer.scala:40) > >at kafka.examples.Producer.<init>(Producer.java:35) > >at > kafka.examples.KafkaConsumerProducerDemo.main(KafkaConsumerProducerDemo.java:23) > > I have to specify the timeout value for zk,like this, > zk.connectiontimeout.ms=10000 and the client could connect to zk server > successfully. > > But another new exception is thrown again: > >Exception in thread "Thread-0" java.nio.channels.ClosedChannelException > >at sun.nio.ch.SocketChannelImpl.ensureWriteOpen(Unknown Source) > >at sun.nio.ch.SocketChannelImpl.write(Unknown Source) > >at > kafka.network.BoundedByteBufferSend.writeTo(BoundedByteBufferSend.scala:48) > >at kafka.network.Send$class.writeCompletely(Transmission.scala:76) > >at > kafka.network.BoundedByteBufferSend.writeCompletely(BoundedByteBufferSend.scala:25) > >at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:88) > >at kafka.producer.SyncProducer.send(SyncProducer.scala:87) > >at kafka.producer.SyncProducer.send(SyncProducer.scala:117) > >at > kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:116) > >at > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102) > >at > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102) > >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:102) > >at kafka.producer.Producer.zkSend(Producer.scala:143) > >at kafka.producer.Producer.send(Producer.scala:105) > >at kafka.javaapi.producer.Producer.send(Producer.scala:104) > >at kafka.examples.Producer.run(Producer.java:45) > > Hope someone could help me, thanks very much! > > > > > >SuoNayi > > > > > > >
