Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 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 ?

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)

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB