副本管理器
kafka中的副本机制使得整个集群只要保证至少有一个副本存活就不会影响整个集群的工作,大大提高了kafka集群的可用性。
在所有副本节点中,有一个节点作为Leader负责接收客户端的读写操作,其他副本节点作为Follower从Leader节点复制数据进行数据同步
ReplicaManager副本管理器负责对副本管理,主要包括对控制器发送的StopReplicaRequest、UpdateMetadataRequest、以及LeaderAndIsrRequest进行处理,维护副本ISR变化以及Follower与Leader数据同步的管理