kafka-connect-elasticsearch
kafka-connect-elasticsearch copied to clipboard
Add Scripted Upsert Functionality
Problem
Scripted Upserts are not currently possible inside of the Update Request sent to ElasticSearch
Also, the Kafka Payload is always sent in as either doc or upsert.
Solution
Add SCRIPTED_UPSERT write.method and custom logic in DataConverter.java to handle parameter injection as well as script injection into ES UpdateRequest
Does this solution apply anywhere else?
- [ ] yes
- [x] no
If yes, where?
Test Strategy
Testing done:
- [x] Unit tests
- [ ] Integration tests
- [ ] System tests
- [ ] Manual tests
Release Plan
Please review @sp-gupta @kkonstantine @snehashisp
Please review @sp-gupta @kkonstantine @snehashisp