'Return True iff this consumer can/should join a broker-coordinated group.'

def _use_consumer_group(self):

    if (self.config['api_version'] < (0, 9)):
        return False
    elif (self.config['group_id'] is None):
        return False
    elif (not self._subscription.partitions_auto_assigned()):
        return False
    return True
