Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support UPDATE/DELETE #28

Open
HolgerKache opened this issue Jun 23, 2017 · 0 comments
Open

Support UPDATE/DELETE #28

HolgerKache opened this issue Jun 23, 2017 · 0 comments

Comments

@HolgerKache
Copy link
Contributor

Cloudant sink connector supports append-only today. There are two different schemes for the _id using the replication setting as documented here: https://github.com/cloudant-labs/kafka-connect-cloudant#cloudant-as-sink

With replication=true the sink connector would honor the document _id during insert into the target db but does NOT perform UPDATE or DELETE on the document. So in a way the term “replication” is misleading.

To actually support replication we need to add information to the event that carries the action details (INSERT, UPDATE, DELETE) along with the source document _id and the document body.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant