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