KafkaController 分区Rebalance平衡机制

private def checkAndTriggerPartitionRebalance(): Unit = {   if (isActive()) {     trace("checking need to trigger partition rebalance")     // 获取(存活的broker,AR副本集) => (2,Map([message,0]-> List(2, 0), [

>>阅读原文<<