What does that mean? I have one zk and one kafka and one cient trying to pull from kafka.
Thanks On Thu, Feb 13, 2014 at 8:16 AM, Guozhang Wang <wangg...@gmail.com> wrote: > It means the leader information has not propagated to the brokers, hence > when clients asked for the leaders of the interested partitions this error > is thrown. > > Have you created the topic manually before you try to produce/consume? > > Guozhang > > > On Wed, Feb 12, 2014 at 4:05 PM, David Montgomery < > davidmontgom...@gmail.com > > wrote: > > > I just built a new kafka server 0.8.0. How I am getting the below in the > > logs. What does it mean? > > > > > > [2014-02-13 00:01:43,034] ERROR [KafkaApi-1392248055] Error while > fetching > > metadata for partition [topic-pixel,0] (kafka.server.KafkaApis) > > kafka.common.LeaderNotAvailableException: Leader not available for > > partition [topic-pixel,0] > > at > > kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:474) > > at > > kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:462) > > 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.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:462) > > at kafka.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:458) > > 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.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.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:458) > > at kafka.server.KafkaApis.handle(KafkaApis.scala:68) > > at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42) > > at java.lang.Thread.run(Thread.java:744) > > [2014-02-13 00:01:43,034] ERROR [KafkaApi-1392248055] Error while > fetching > > metadata for partition [topic-pixel,1] (kafka.server.KafkaApis) > > > > > > -- > -- Guozhang >
