Did you create the topic without a # of partitions then try to delete/recreate it? I've had that happen to me before. Try shutting down everything (including zookeeper) and restarting.
On Tue, Apr 23, 2013 at 9:08 PM, Jun Rao <jun...@gmail.com> wrote: > Does this happen on every message that you type in producer console? > > Thanks, > > Jun > > > On Tue, Apr 23, 2013 at 4:15 PM, Yin Yin <yin....@outlook.com> wrote: > > > 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 > > >
