You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Any suggestion can be provide to resolve the
Ignoring EXTERNAL version conflict for operation INDEX on document
Whether Kafka level or connector level ?
write.method=UPSERT works find for not sending version external. But as per the code. DELETE still sends version so it is causing the DELETE ignoring issue. when record value NULL. I am confused this logic. How to avoid DELETE with EXTERNAL version send and if change UPSERT then again index or updating documents causing issue.
final String id = config.shouldIgnoreKey(record.topic())
? String.format("%s+%d+%d", record.topic(), record.kafkaPartition(), record.kafkaOffset())
: convertKey(record.keySchema(), record.key());
Any suggestion can be provide to resolve the
Ignoring EXTERNAL version conflict for operation INDEX on document
Whether Kafka level or connector level ?
write.method=UPSERT works find for not sending version external. But as per the code. DELETE still sends version so it is causing the DELETE ignoring issue. when record value NULL. I am confused this logic. How to avoid DELETE with EXTERNAL version send and if change UPSERT then again index or updating documents causing issue.
final String id = config.shouldIgnoreKey(record.topic())
? String.format("%s+%d+%d", record.topic(), record.kafkaPartition(), record.kafkaOffset())
: convertKey(record.keySchema(), record.key());
// delete
if (record.value() == null) {
return maybeAddExternalVersioning(new DeleteRequest(index).id(id), record);
}
The text was updated successfully, but these errors were encountered: