kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Neha Narkhede <neha.narkh...@gmail.com>
Subject Re: NotLeaderForPartitionException after creating a topic
Date Fri, 01 Nov 2013 10:55:08 GMT
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)

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