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

Switch to Threaded View
Kafka, mail # user - Re: LeaderNotAvailableException


Copy link to this message
-
Re: LeaderNotAvailableException
Jun Rao 2013-05-15, 03:47
Any exceptions in the broker log (including state-change log)?

Thanks,

Jun
On Tue, May 14, 2013 at 9:12 AM, Yu, Libo <[EMAIL PROTECTED]> wrote:

> Hi,
>
> I have 3 machines on a cluster. Normally, I start zookeepers on all three
> before I launch kafka servers. Today for each machine I start zookeeper
> first and then kafka server. I noticed this error from one machine:
> The process was  still running but it seems the server stopped responding.
> I published some data to the cluster. As soon as the producer connected
> to this broker, it disconnected.
>
>
> [2013-05-14 11:51:02,976] ERROR Error while fetching metadata for
> partition [jm85
> 305.topic.1,0] (kafka.admin.AdminUtils$)
> kafka.common.LeaderNotAvailableException: Leader not available for topic
> jm85305.
> topic.1 partition 0
>         at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:217)
>         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.s
> cala: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$$anonfun$fetchTopicMetadataFromZk$1.apply(AdminUtils.scala:194)
>         at
> kafka.admin.AdminUtils$$anonfun$fetchTopicMetadataFromZk$1.apply(AdminUtils.scala:194)
>         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.immutable.Set$Set1.foreach(Set.scala:81)
>         at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
>         at scala.collection.immutable.Set$Set1.map(Set.scala:68)
>         at
> kafka.admin.AdminUtils$.fetchTopicMetadataFromZk(AdminUtils.scala:194)
>         at
> kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:463)
>         at kafka.server.KafkaApis.handle(KafkaApis.scala:67)
>         at
> kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41)
>         at java.lang.Thread.run(Thread.java:722)
> Caused by: java.util.NoSuchElementException: head of empty list
>         at scala.collection.immutable.Nil$.head(List.scala:386)
>         at scala.collection.immutable.Nil$.head(List.scala:383)
>         at kafka.admin.AdminUtils$$anonfun$3.apply(AdminUtils.scala:215)
>         ... 20 more
> [2013-05-14 11:51:03,034] INFO Closing socket connection to /XX.XX.XX.XX.
> (kafka.network.Processor)
> [2013-05-14 11:51:03,416] ERROR Error while fetching metadata for
> partition [jm85305.topic.1,0] (kafka
>
> Regards,
>
> Libo
>
>