<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 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()