Exception from kafka server 0.8

["Yu, Libo " <li...@citi.com>]

I got this error while running produce performance test.

This is from server:
[2013-04-24 15:23:19,082] ERROR Error while fetching metadata for partition [test5,2] (kafka.admin.AdminUtils$)
kafka.common.ReplicaNotAvailableException
        at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:228)
        at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:201)
        at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
        at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
        at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
        at scala.collection.immutable.List.foreach(List.scala:45)
        at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
        at scala.collection.immutable.List.map(List.scala:45)
        at kafka.admin.AdminUtils$.kafka$admin$AdminUtils$$fetchTopicMetadataFromZk(AdminUtils.scala:201)
        at kafka.admin.AdminUtils$$anonfun$fetchTopicMetadataFromZk$1.apply(AdminUtils.scala:194)
        at kafka.admin.AdminUtils$$anonfun$fetchTopicMetadataFromZk$1.apply(AdminUtils.scala:194)
        at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
        at scala.collection.immutable.Set$Set1.foreach(Set.scala:81)
        at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
        at scala.collection.immutable.Set$Set1.map(Set.scala:68)
        at kafka.admin.AdminUtils$.fetchTopicMetadataFromZk(AdminUtils.scala:194)
        at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:463)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:67)
        at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41)
        at java.lang.Thread.run(Thread.java:722)

This is from producer:
[2013-04-24 15:23:28,297] WARN Failed to send producer request with correlation id 5531 to broker 2 with data for partitions [test5,0] (kafka.producer.async.DefaultEventHandler)
java.net.SocketTimeoutException
        at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:226)
        at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
        at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
        at kafka.utils.Utils$.read(Utils.scala:374)
        at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
        at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
        at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
        at kafka.network.BlockingChannel.receive(BlockingChannel.scala:100)
        at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:74)
        at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:71)
        at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.a


Regards,

Libo