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

Switch to Threaded View
Kafka >> mail # user >> NotLeaderForPartitionException after creating a topic

Copy link to this message
Re: NotLeaderForPartitionException after creating a topic
The following exception seems suspicious and I think it is fixed in 0.8
HEAD. Do you mind trying 0.8 HEAD and see if this can still be reproduced ?

NoSuchElementException: key not found: /disk1/test/kafka-data
     at scala.collection.MapLike$class.default(MapLike.scala:223)
     at scala.collection.immutable.Map$Map1.default(Map.scala:93)
     at scala.collection.MapLike$class.apply(MapLike.scala:134)
     at scala.collection.immutable.Map$Map1.apply(Map.scala:93)
     at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:83)
     at kafka.cluster.Partition$$anonfun$1.apply(Partition.scala:149)