Confluent Elasticsearch Sink connector, write.method : "UPSERT" on different key

Question

In COnfluent Elasticsearch Sink connector, I am trying to write in same Elasticsearch index from two different topics. First topic is INSERT and another topic is UPSERT. For UPSERT, I want to update the JSON document based on some other field instead of "_id". IS that possible ? If yes, How can I do that ?

Answer 1

Use key.ignore=false and use existing primary key columns as _id for each json document.