LeaderNotAvailableException

[Vadim Keylis]

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)