I was asking if you could first verify if the topic named "topic-pixel" exists in Kafka using the kafka-topics tool.
Guozhang On Wed, Feb 12, 2014 at 4:27 PM, David Montgomery <davidmontgom...@gmail.com > wrote: > 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 > > > -- -- Guozhang
