Low latency demultiplexer for propagating ordered data to multiple sinks

Abstract

A computer-implemented method includes receiving a series of writes. Each write in the series of writes is requesting respective data to be stored at a database. For each respective write in the series of writes, the method includes: storing the respective data in a buffer associated with one or more data streaming applications; transmitting the respective data to the database; receiving, from the database, 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 order indicator, sending the respective data of the respective write from the buffer to each data streaming application of the one or more data streaming applications based on the order indicator indicating the order the respective data was committed to the database relative to other writes in the series of writes.