code: def rebalance_brokers(self):
          
          for rg in six.itervalues(self.cluster_topology.rgs):
              rg.rebalance_brokers()
docs: Rebalance partition-count across brokers within each replication-group.