18 | PartitionStateMachine：分区状态转换如何实现？

你好，我是胡夕。我来公布上节课的“课后讨论”题答案啦～ 上节课，咱们结合源码重点了解了ReplicaStateMachine的源码。课后我请你自行分析doHandleStateChanges方法中最后一路分支的代码。下面我给出我的答案：最后一路case分支是NonExistentReplica。当进入到这路分支后，代码会遍历所有能够执行状态转换操作的副本。去获取当副本当前的状态以及所在分区的完整副本列表。之后将该副本从副本列表中移除，并将得到的新副本列表更新到Controller元数据缓存中。最后呢，代码将该副本从状态机中移除。 okay，你同意这个说法吗？或者说你有其他的看法吗？我们可以一起讨论下。

triggerOnlineStateChangeForPartitions是将NewPartition、OfflinePartition状态的broker上除待删除主题的分区之外的所有分区移动到OnlinePartition状态的分区上； 触发时机的话有如下几个入口： 1. Controller启动时候； 2. Controller收到UncleanLeaderElectionEnable、TopicUncleanLeaderElectionEnable事件 3. 副本变成Offline状态时候

kafka集群间分区级数据复制如何做？

老师我想问下，正常关闭Broker 和 leader下线有什么区别？不都是leader下线嘛

在doHandleStateChanges方法的NewPartition分支中，首先在ZK写入了Leader和ISR数据，如果成功了就已经把状态置为了OnlinePartition；这里的操作和之后进行的Leader选举操作，这两个里面的Leader是怎么样的关系呢，还是说这个操作就是状态转换过程中OnlinePartition可以因为触发Leader选举而再次将状态置为OnlinePartition的过程，那这个操作的意义是什么呢？

请问问什么AR的顺序和ISR的顺序有差异呢？

看完怎么感觉OnlinePartition分支里面leader选举执行了2次？

其实我一直好奇，isr里的副本，其实不是完全同步的，有特别小的差距。leader选举的时候会处理这一点差距不？不处理的话会不会丢数据？

controllerBrokerRequestBatch.newBatch() 是清空的意思? 我看的2.7.1 版本的代码,并非如此吧.后面的 clear() 倒确实如此. def newBatch(): Unit = { // raise error if the previous batch is not empty if (leaderAndIsrRequestMap.nonEmpty) throw new IllegalStateException("Controller to broker state change requests batch is not empty while creating " + s"a new one. Some LeaderAndIsr state changes $leaderAndIsrRequestMap might be lost ") if (stopReplicaRequestMap.nonEmpty) throw new IllegalStateException("Controller to broker state change requests batch is not empty while creating a " + s"new one. Some StopReplica state changes $stopReplicaRequestMap might be lost ") if (updateMetadataRequestBrokerSet.nonEmpty) throw new IllegalStateException("Controller to broker state change requests batch is not empty while creating a " + s"new one. Some UpdateMetadata state changes to brokers $updateMetadataRequestBrokerSet with partition info " + s"$updateMetadataRequestPartitionInfoMap might be lost ") }