def METHOD_NAME(self, ids):
    if self.bulk:
        AsyncIndicator.bulk_creation(ids, self.referenced_type, self.domain, self.config_ids)
    else:
        for id_ in ids:
            change = FakeChange(id_, self.fake_change_doc)
            AsyncIndicator.update_from_kafka_change(change, self.config_ids)