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
Handle v4 AllocateIds and route remotely if it matches the target app.
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer._use_consumer_group--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/python-compat-runtime/appengine-compat/exported_appengine_sdk/google/appengine/ext/datastore_admin/remote_api_put_stub.py/RemoteApiDatastoreV4Stub._Dynamic_AllocateIds