Re: NotLeaderForPartitionException after creating a topic

2013-11-01 Thread Neha Narkhede
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 scal

NotLeaderForPartitionException after creating a topic

2013-11-01 Thread Henry Ma
Hello, I am using 0.8.0-beta1, with two brokers. After using bin/kafka-create-topic.sh created a topic named "ead_click", under bin/kafka-list-topic.sh I can see the topic seems to be created successfully: [2013-11-01 15:49:35,388] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient