Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka, mail # user - LeaderNotAvailable Exception


+
Yin Yin 2013-04-23, 23:16
Copy link to this message
-
Re: LeaderNotAvailable Exception
Jun Rao 2013-04-24, 01:08
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
>

 
+
Chris Curtin 2013-04-24, 14:40
+
Yin Yin 2013-04-25, 00:21
+
Jun Rao 2013-04-25, 03:58
+
Yin Yin 2013-04-25, 06:00
+
Jun Rao 2013-04-25, 14:21
+
Yin Yin 2013-04-25, 17:27
+
Jun Rao 2013-04-26, 04:31
+
Jason Rosenberg 2013-05-06, 23:06
+
Jason Rosenberg 2013-05-06, 23:10
+
Jun Rao 2013-05-07, 04:33