Multi-master data replication in a distributed multi-tenant system

A database system comprising one or more hardware processors, the database system configurable to cause:

• monitoring, by a change detection thread running on a first server associated with a first instance of a plurality of instances of a replicated database, for changes to any of a plurality of records within one or more shared tables of the replicated database;
• responsive to detection of a change to a record of the plurality of records, storing, by the change detection thread, an item onto a queue containing information regarding the change;
• and
• packaging groups of changes, represented by multiple items on the queue, into chunks associated with a plurality of changed records, the chunks containing metadata about the plurality of changed records, the metadata including timestamp boundaries indicative of the plurality of changed records associated with the chunk, and the timestamp boundaries including a first timestamp indicating an earliest time at which the plurality of changed records was modified and a second timestamp indicating a latest time at which the plurality of changed records was modified, wherein the timestamp boundaries of a first chunk of the chunks overlap the timestamp boundaries of a second chunk of the chunks.

A computer program product comprising a non-transitory computer-readable medium storing computer-readable program code capable of being executed by one or more processors when retrieved from the non-transitory computer-readable medium, the program code comprising instructions configurable to cause:

• monitoring, by a change detection thread running on a first server associated with a first instance of a plurality of instances of a replicated database, for changes to any of a plurality of records within one or more shared tables of the replicated database;
• responsive to detection of a change to a record of the plurality of records, storing, by the change detection thread, an item onto a queue containing information regarding the change;
• and
• packaging groups of changes, represented by multiple items on the queue, into chunks associated with a plurality of changed records, the chunks containing metadata about the plurality of changed records, the metadata including timestamp boundaries indicative of the plurality of changed records associated with the chunk, and the timestamp boundaries including a first timestamp indicating an earliest time at which the plurality of changed records was modified and a second timestamp indicating a latest time at which the plurality of changed records was modified, wherein the timestamp boundaries of a first chunk of the chunks overlap the timestamp boundaries of a second chunk of the chunks.