Bulk data extraction system

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

• sending a first request to a data storage system that is accessible to a plurality of groups of users, wherein the first request is sent prior to initiation of a bulk data extraction for a first group of the plurality of groups, wherein the bulk data extraction is a transfer of messages for past data events of the first group that meet one or more specified criteria;
• in response to the first request, receiving, from the data storage system, a first notification message that includes a particular event identifier for a most recent data event generated at the data storage system;
• receiving, from the data storage system, those messages associated with the bulk data extraction for the first group;
• and
• subsequent to completion of the bulk data extraction, sending, by the streaming server system to the data storage system, a request to subscribe to notification messages for data events associated with the first group that meet at least one of the one or more specified criteria, wherein the request to subscribe specifies the particular event identifier as a starting point of data events for which to send the notification messages.

A method, comprising:

• receiving, at a data storage system accessible to a plurality of groups of users, a first request from a streaming server system, wherein the first request is received prior to initiation of a bulk data extraction for a first group of the plurality of groups, wherein the bulk data extraction is a transfer of messages for past data events of the first group that meet one or more specified criteria;
• in response to the first request, sending, by the data storage system to the streaming server system, a first notification message that includes a particular event identifier for a most recent data event generated at the data storage system;
• sending, by the data storage system to the streaming server system, those messages associated with the bulk data extraction for the first group;
• and
• receiving, by the data storage system from the streaming server system, a request to subscribe to notification message for data events associated with the first group that meet at least one of the one or more specified criteria, wherein the request to subscribe specifies the particular event identifier as a starting point of data events for which to send the notification messages.