Low Latency Demultiplexer for Propagating Ordered Data to Multiple Sinks

A system comprising:

• data processing hardware;
• and
• memory hardware in communication with the data processing hardware, the memory hardware storing instructions that when executed on the data processing hardware cause the data processing hardware to perform operations comprising:
• receiving a series of writes, each write in the series of writes requesting respective data to be stored at a database in communication with the data processing hardware;
• and
• for each respective write in the series of writes:
• storing the respective data in a first buffer associated with a first data streaming application;
• storing the respective data in a second buffer associated with a second data streaming application;
• transmitting the respective data to the database;
• receiving, from the database, confirmation that the respective data of the respective write has been committed to the database, the confirmation comprising an order indicator indicating an order the respective data of the respective write was committed to the database relative to other writes in the series of writes;
• and
• in response to receiving the confirmation that the respective data of the respective write has been committed to the database:
• sending the respective data of the respective write from the first buffer to the first data streaming application based on the order indicator indicating the respective data was committed to the database relative to other writes in the series of writes;
• and
• sending the respective data of the respective write from the second buffer to the second data streaming application based on the order indicator indicating the respective data was committed to the database relative to other writes in the series of writes.