kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From SuoNayi <suonayi2...@163.com>
Subject Reply:Bad user experience when out of box
Date Tue, 07 Feb 2012 10:00:36 GMT
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