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

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


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