Coordinated Replication of Heterogeneous Database Stores

A system, comprising:

• a memory;
• and
• at least one processor coupled to the memory and configured to:
• determine a synchronization point based on a commit log of a primary data center, wherein the primary data center comprises a primary master server, and wherein the synchronization point corresponds to a logged position for each of a plurality of primary slave servers;
• request a current log position of each of a plurality of secondary slave servers associated with a secondary master server of a secondary data center, wherein each of the secondary slave servers corresponds to a replication of one of the primary slave servers, and wherein the secondary master server comprises a replication of the primary master server;
• determine that the current log position of at least one of the secondary slave servers does not correspond to the logged position of a corresponding primary slave server relative to the synchronization point;
• receive, subsequent to the determining, an update indicating that the current log position of each of the secondary slave servers corresponds to the logged position of each of the relative corresponding primary slave servers;
• and
• initiate a replay of each of the secondary slave servers up to the synchronization point.

A non-transitory computer-readable device having instructions stored thereon that, when executed by at least one computing device, causes the at least one computing device to perform operations comprising:

• determining a synchronization point based on a commit log of a primary data center, wherein the primary data center comprises a primary master server, and wherein the synchronization point corresponds to a logged position for each of a plurality of primary slave servers;
• requesting a current log position of each of a plurality of secondary slave servers associated with a secondary master server of a secondary data center, wherein each of the secondary slave servers corresponds to a replication of one of the primary slave servers, and wherein the secondary master server comprises a replication of the primary master server;
• determining that the current log position of at least one of the secondary slave servers does not correspond to the logged position of a corresponding primary slave server relative to the synchronization point;
• receiving, subsequent to the determining, an update indicating that the current log position of each of the secondary slave servers corresponds to the logged position of each of the relative corresponding primary slave servers;
• and
• initiating a replay of each of the secondary slave servers up to the synchronization point.