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
Return True iff this consumer can/should join a broker-coordinated group.
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer._use_consumer_group