def _get_coordinator_for_group(self, group):
        """
        Returns the coordinator broker for a consumer group.

        ConsumerCoordinatorNotAvailableCode will be raised if the coordinator
        does not currently exist for the group.

        OffsetsLoadInProgressCode is raised if the coordinator is available
        but is still loading offsets from the internal topic
        """

        resp = self.send_consumer_metadata_request(group)

        # If there's a problem with finding the coordinator, raise the
        # provided error
        kafka_common.check_error(resp)

        # Otherwise return the BrokerMetadata
        return BrokerMetadata(resp.nodeId, resp.host, resp.port)