def _get_coordinator_for_group(self, group):
resp = self.send_consumer_metadata_request(group)<EOL>kafka_common.check_error(resp)<EOL>return BrokerMetadata(resp.nodeId, resp.host, resp.port)<EOL>
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