kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jun Rao <jun...@gmail.com>
Subject Re: Reply:Bad user experience when out of box
Date Tue, 07 Feb 2012 17:20:47 GMT
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 <suonayi2006@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 <suonayi2006@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
> >
> >
> >
>

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