You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Yin Yin <yi...@outlook.com> on 2013/04/24 01:15:39 UTC
LeaderNotAvailable Exception
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
Re: LeaderNotAvailable Exception
Posted by Chris Curtin <cu...@gmail.com>.
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 <ju...@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 <yi...@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
> >
>
Re: LeaderNotAvailable Exception
Posted by Jun Rao <ju...@gmail.com>.
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 <yi...@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
>