kafka源码解析-分区副本的分配

主要介绍是未指定机架信息的分配策略，kafka版本是2.0.0，具体实现为kafka.admin.AdminUtils.scala文件中的数组 assignReplicasToBrokersRackUnaware()方法，该方法的内容以下：scala private def assignReplicasToBrokersRackUnaware(nPartitions: Int,//分区数

>>阅读原文<<