kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vadim Keylis <vkeylis2...@gmail.com>
Subject LeaderNotAvailableException
Date Wed, 07 Aug 2013 05:08:52 GMT
We are using kafka08 beta1. We had 6 kafka in the tier. I have replication
set to 3. Then 3 servers were removed using control shutdown method. I am
getting the  error bellow after that.
What went wrong during shutdown? How to recover from the error? What steps
to take in order to avoid in the future?

Thanks so much in advance.


[2013-08-06 21:56:46,044] ERROR [KafkaApi-7] Error while fetching metadata
for partition [junit2_analytics_data_log,0] (kafka.server.KafkaApis)
kafka.common.LeaderNotAvailableException: Leader not available for
partition [junit2_analytics_data_log,0]
        at
kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:468)
        at
kafka.server.KafkaApis$$anonfun$17$$anonfun$20.apply(KafkaApis.scala:456)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
        at
scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
        at scala.collection.immutable.List.foreach(List.scala:76)
        at
scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
        at scala.collection.immutable.List.map(List.scala:76)
        at kafka.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:456)
        at kafka.server.KafkaApis$$anonfun$17.apply(KafkaApis.scala:452)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
        at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
        at
scala.collection.immutable.HashSet$HashSet1.foreach(HashSet.scala:130)
        at
scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:275)
        at
scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
        at
scala.collection.immutable.HashSet.scala$collection$SetLike$$super$map(HashSet.scala:33)
        at scala.collection.SetLike$class.map(SetLike.scala:93)
        at scala.collection.immutable.HashSet.map(HashSet.scala:33)
        at
kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:452)
        at kafka.server.KafkaApis.handle(KafkaApis.scala:69)
        at
kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
        at java.lang.Thread.run(Thread.java:662)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message