kafka源碼解析-分區副本的分配

主要介紹是未指定機架信息的分配策略，kafka版本是2.0.0，具體實現爲kafka.admin.AdminUtils.scala文件中的數組 assignReplicasToBrokersRackUnaware()方法，該方法的內容以下：scala private def assignReplicasToBrokersRackUnaware(nPartitions: Int,//分區數

>>阅读原文<<