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 ?
ava.util.
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)
