Buffering Techniques for a Change Record Stream of a Database

A non-transitory computer-readable medium having computer instructions stored thereon that are capable of being executed by a computer system to cause operations comprising:

• sending, to a server, a request for a stream of change event records for a multi-tenant database, wherein a given change event record is indicative of a modification made to the database by one of a plurality of tenants;
• in response to the sending, receiving one or more shards from the server, wherein a given shard includes one or more change event records associated with a subset of the plurality of tenants over a particular period of time;
• storing the received change event records from the one or more shards into one or more buffers;
• maintaining a log, separate from the one or more buffers, the log including information about respective received shards, including an order in which the respective shards are received;
• and
• in response to receiving a query from a given one of the plurality of tenants, processing the query using the log to identify change event records associated with the given tenant.

A method, comprising:

• sending, by a computer system to a server, a request for a stream of change event records for a database, wherein a given change event record is indicative of a modification made to the database by one of a plurality of users;
• in response to the sending, receiving, by the computer system from the server, a series of shards from the stream, wherein a given shard includes one or more change event records created during a particular period of time;
• storing, by the computer system into a buffer, change event records from a particular shard of the series;
• tracking, by the computer system, information associated with the particular shard, including an indication of a parent shard associated with the particular shard;
• and
• using, by the computer system, the tracked information and the buffer to process a query from a given user.