code: def acquire_partition(self, partition, source_broker):
          
          broker_dest = self._elect_dest_broker(partition)
          if not broker_dest:
              raise NotEligibleGroupError(
                  "No eligible brokers to accept partition {p}".format(p=partition),
              )
          source_broker.move_partition(partition, broker_dest)
docs: Move a partition from a broker to any of the eligible brokers
          of the replication group.
  
          :param partition: Partition to move
          :param source_broker: Broker the partition currently belongs to