'Return node_id of group coordinator.
Arguments:
group (str): name of consumer group
Returns:
int: node_id for group coordinator'

def coordinator_for_group(self, group):

    return self._groups.get(group)
