confluentinc / kafka-connect-elasticsearch

Kafka Connect Elasticsearch connector
Other
15 stars 436 forks source link

UPSERT mode for DELETE operation not send external version #718

Open ramyogi7283 opened 1 year ago

ramyogi7283 commented 1 year ago

Problem

When UPSERT mode DELETE still sends the version s external that is causing issue. ELASTIC index snapshot and restore to different environment where Kafka offset values are not same as incremental from snapshot index this external versioning creates problem for DELETE operations even we changes write.method=UPSERT. https://github.com/confluentinc/kafka-connect-elasticsearch/issues/709

Solution

DELETE operation needs to send version external or not based upon the INSERT vs UPSERT method.

Does this solution apply anywhere else?
If yes, where?

Test Strategy

Testing done:

Release Plan

cla-assistant[bot] commented 1 year ago

CLA assistant check
All committers have signed the CLA.

cla-assistant[bot] commented 1 year ago

CLA assistant check
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
You have signed the CLA already but the status is still pending? Let us recheck it.