@DeepakMa6 The streaming upserts method does not support updating, replacing, and removing identities. New identities are created if they do not exist. Hence the identity operation must always be set to create. If an identity already exists, the operation is a no-op.