I tried to run the kafka 0.8 version as instructed in Quick Start. The kafka server shows the following message when I launch the producer. ERROR Error while fetching metadata for partition [test,0] (kafka.admin.AdminUtils$)kafka.common.LeaderNotAvailableException: No leader exists for partition 0 at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:219) 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$.fetchTopicMetadataFromZk(AdminUtils.scala:190) at kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:479) at kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:465) at scala.collection.immutable.Set$Set1.foreach(Set.scala:81) at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:464) at kafka.server.KafkaApis.handle(KafkaApis.scala:67) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41) at java.lang.Thread.run(Unknown Source) Then, when I type a message in the producer console, the server console pops out WARN [KafkaApi-0] Leader not local for topic test partition 0 on broker 0 (kafka.server.KafkaApis) Consumer console also didn't get any message. Any help is appreciated. Thanks

> I tried to run the kafka 0.8 version as instructed in Quick Start. The> kafka server shows the following message when I launch the producer. ERROR> Error while fetching metadata for partition [test,0]> (kafka.admin.AdminUtils$)> kafka.common.LeaderNotAvailableException: No leader exists for partition 0> at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:219)> 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$.fetchTopicMetadataFromZk(AdminUtils.scala:190)> at> kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:479)> at> kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:465)> at scala.collection.immutable.Set$Set1.foreach(Set.scala:81)> at> kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:464)> at kafka.server.KafkaApis.handle(KafkaApis.scala:67)> at> kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41)> at java.lang.Thread.run(Unknown Source) Then, when I type a> message in the producer console, the server console pops out WARN> [KafkaApi-0] Leader not local for topic test partition 0 on broker 0> (kafka.server.KafkaApis) Consumer console also didn't get any message. Any> help is appreciated. Thanks>