AlimZanibekov opened a new pull request #7329:
URL: https://github.com/apache/pulsar/pull/7329
### Motivation
I need to use ElasticSearch via Pulsar as a database but not as a dump of
logs that’s why I implemented the possibility to update and delete records, as
well as to set id when creating a record
### Modifications
Record processing
- added "*ACTION*" [Record] property which can be "*UPSERT*" or
"*DELETE*", default value is "*UPSERT*"
- added "*ID*" [Record] property which provides record id (required for
"*DELETE*")
Tests
- added *updateSingleRecordTest*
- added *deleteSingleRecordTest*
- renamed *singleRecordTest-> insertSingleRecordTest*
### Verifying this change
This change added tests and can be verified as follows:
- *Extended unit tests (ElasticSearchSinkTests) for update and delete
requests*
### Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API: no
- The schema: no
- The default values of configurations: no
- The wire protocol: no
- The rest endpoints: no
- The admin cli options: no
- Anything that affects deployment: don't know
### Documentation
- Does this pull request introduce a new feature: yes
- Is the feature documented: not documented
> I didn't find a documentation section for sink [Record] interface
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
