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 Plain View
Kafka >> mail # user >> LeaderNotAvailable Exception


Copy link to this message
-
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
     
 
+
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
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