first,i increase some partitions for a topic,and is ok, then i do kafka-reassign-partitions.sh ,and it speed long times to replicated data, and a partition status as "partition: 68 leader: 5 replicas: 8,0,5,1 isr: 5,1" so i do kafka-preferred-replica-election.sh & kafka-reassign-partitions.sh,then i find the partitions are decrease,the partition nums turn back to i do increase operation. what could cause this? and how i can recover to increase partitions.
log as follow: ERROR [Partition state machine on Controller 0]: Error while moving some partitions to OnlinePartition state (kafka. controller.PartitionStateMachine) kafka.common.StateChangeFailedException: Controller 0 epoch 16 initiated state change for partition [Topic_1,85] to OnlinePartition fai led because the partition state machine has not started at kafka.controller.PartitionStateMachine.kafka$controller$PartitionStateMachine$$handleStateChange(PartitionStateMachine.scala:162) at kafka.controller.PartitionStateMachine$$anonfun$handleStateChanges$2.apply(PartitionStateMachine.scala:125) at kafka.controller.PartitionStateMachine$$anonfun$handleStateChanges$2.apply(PartitionStateMachine.scala:124) at scala.collection.immutable.HashSet$HashSet1.foreach(HashSet.scala:130) at scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:275) at scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:275) at scala.collection.immutable.HashSet$HashTrieSet.foreach(HashSet.scala:275) at kafka.controller.PartitionStateMachine.handleStateChanges(PartitionStateMachine.scala:124) at kafka.controller.KafkaController.onPreferredReplicaElection(KafkaController.scala:618) at kafka.controller.PreferredReplicaElectionListener$$anonfun$handleDataChange$2.apply$mcV$sp(KafkaController.scala:1265) at kafka.controller.PreferredReplicaElectionListener$$anonfun$handleDataChange$2.apply(KafkaController.scala:1253) at kafka.controller.PreferredReplicaElectionListener$$anonfun$handleDataChange$2.apply(KafkaController.scala:1253) at kafka.utils.Utils$.inLock(Utils.scala:538) at kafka.controller.PreferredReplicaElectionListener.handleDataChange(KafkaController.scala:1253) at org.I0Itec.zkclient.ZkClient$6.run(ZkClient.java:547) at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) Thanks, Lax