Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> LeaderNotAvailable Exception


Copy link to this message
-
Re: LeaderNotAvailable Exception
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 <[EMAIL PROTECTED]> 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 <[EMAIL PROTECTED]> 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
> >
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB