Cool. Would you mind describing the bug so it helps other Kafka users as well?
On Sat, Mar 8, 2014 at 8:45 AM, Bae, Jae Hyeon <metac...@gmail.com> wrote: > Never mind, this was caused by a bug of my apache curator-zkclient bridge > module. > > > On Fri, Mar 7, 2014 at 6:14 PM, Bae, Jae Hyeon <metac...@gmail.com> wrote: > > > I started from a fresh but I deployed the working version synced from the > > latest trunk, not a release version. > > > > I just executed kafka.admin.TopicCommand with --create option. > > > > > > > > > > On Fri, Mar 7, 2014 at 5:56 PM, Neha Narkhede <neha.narkh...@gmail.com > >wrote: > > > >> Starting from a fresh and working deployment, what admin commands or > steps > >> lead you to these errors? This error basically points to an unexpected > >> state change, which could be a bug. I'm looking for steps to be able to > >> reproduce the bug. > >> > >> Thanks, > >> Neha > >> > >> > >> On Fri, Mar 7, 2014 at 1:59 PM, Bae, Jae Hyeon <metac...@gmail.com> > >> wrote: > >> > >> > How can I prevent these errors coming? > >> > > >> > When I created 9 partitions on 3 instances and 2 replication-factor, I > >> > didn't have any error. But when I created 36 partitions on 12 > >> instances, I > >> > got these errors. > >> > > >> > > >> > 2014-03-07 18:19:28,208] ERROR Controller 9 epoch 12 initiated state > >> change > >> > of replica 9 for partition [request_trace,3] from NonExistentReplica > to > >> > NewReplica failed (state.change.logger) > >> > kafka.common.StateChangeFailedException: Replica 9 for partition > >> > [request_trace,3] cannot be moved to NewReplicastate as it is being > >> > requested to become leader > >> > at > >> > > >> > > >> > kafka.controller.ReplicaStateMachine.handleStateChange(ReplicaStateMachine.scala:160) > >> > at > >> > > >> > > >> > kafka.controller.ReplicaStateMachine$$anonfun$handleStateChanges$2.apply(ReplicaStateMachine.scala:96) > >> > at > >> > > >> > > >> > kafka.controller.ReplicaStateMachine$$anonfun$handleStateChanges$2.apply(ReplicaStateMachine.scala:96) > >> > at > >> > scala.collection.immutable.HashSet$HashSet1.foreach(HashSet.scala:123) > >> > at > >> > > >> > scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:322) > >> > at > >> > > >> > scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:322) > >> > at > >> > > >> > > >> > kafka.controller.ReplicaStateMachine.handleStateChanges(ReplicaStateMachine.scala:96) > >> > at > >> > > >> > > >> > kafka.controller.KafkaController.onNewPartitionCreation(KafkaController.scala:464) > >> > at > >> > > >> > > >> > kafka.controller.KafkaController.onNewTopicCreation(KafkaController.scala:452) > >> > at > >> > > >> > > >> > kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply$mcV$sp(PartitionStateMachine.scala:421) > >> > at > >> > > >> > > >> > kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply(PartitionStateMachine.scala:403) > >> > at > >> > > >> > > >> > kafka.controller.PartitionStateMachine$TopicChangeListener$$anonfun$handleChildChange$1.apply(PartitionStateMachine.scala:403) > >> > at kafka.utils.Utils$.inLock(Utils.scala:538) > >> > at > >> > > >> > > >> > kafka.controller.PartitionStateMachine$TopicChangeListener.handleChildChange(PartitionStateMachine.scala:402) > >> > at org.I0Itec.zkclient.ZkClient$7.run(ZkClient.java:576) > >> > at > org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) > >> > > >> > > > > >
