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
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