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

DBZ-182 Restart MongDB initial sync if necessary #176

Merged
merged 1 commit into from Feb 3, 2017

Conversation

rhauch
Copy link
Member

@rhauch rhauch commented Feb 2, 2017

Corrected the MongoDB connector upon startup to restart an initial sync if the previously recorded offset signals that an initial sync was not completed in the prior run.

Also change the connector’s replicator to buffer the last record during an initial sync so that, upon completion of the initial sync, the last record can be updated with an offset that reflects that the initial sync was completed. This way, if the initial sync is completed but there are no other events in the oplog, the connector will still consider the initial sync as completed.

Corrected the MongoDB connector upon startup to restart an initial sync if the previously recorded offset signals that an initial sync was not completed in the prior run.

Also change the connector’s replicator to buffer the last record during an initial sync so that, upon completion of the initial sync, the last record can be updated with an offset that reflects that the initial sync was completed. This way, if the initial sync is completed but there are no other events in the oplog, the connector will still consider the initial sync as completed.
@rhauch rhauch merged commit 3ff9ca8 into debezium:master Feb 3, 2017
@rhauch rhauch deleted the dbz-182 branch February 6, 2017 16:24
bdbene added a commit to bdbene/debezium that referenced this pull request Jun 23, 2023
bdbene added a commit to bdbene/debezium that referenced this pull request Jun 23, 2023
methodmissing pushed a commit to methodmissing/debezium that referenced this pull request Apr 6, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
1 participant