Fragmentation of time-associated data streams

A system, comprising:

• at least one computing device;
• and
• an endpoint service executable in the at least one computing device, wherein when executed the endpoint service causes the at least one computing device to at least:
• receive a first fragment of a stream of time-associated data via a network using an application-layer protocol from a producer, the first fragment being identified as having a first timestamp assigned by the producer;
• assign a first unique fragment identifier and a second timestamp to the first fragment;
• and
• send a first acknowledgement, a second acknowledgement after sending the first acknowledgement, and a third acknowledgment after sending the second acknowledgement for the first fragment to the producer via the network using the application-layer protocol, the first acknowledgement indicating that the endpoint service has begun to receive data from the first fragment, the second acknowledgement indicating that the endpoint service has completed receiving the data from the first fragment, the third acknowledgment indicating that the endpoint service has completed storing the first fragment in a data store, wherein the first, second, and third acknowledgements identify the first fragment by the first timestamp.

A method, comprising:

• receiving, by at least one computing device, a first fragment of a stream of time-associated data via a network using an application-layer protocol from a producer, the first fragment being identified as having a first timestamp assigned by the producer;
• assigning, by the at least one computing device, a first unique fragment identifier and a second timestamp to the first fragment;
• and
• sending, by the at least one computing device, a first acknowledgement, a second acknowledgement after sending the first acknowledgement, and a third acknowledgment after sending the second acknowledgement for the first fragment to the producer via the network using the application-layer protocol, the first acknowledgement indicating that an endpoint service has begun to receive data from the first fragment, the second acknowledgement indicating that the endpoint service has completed receiving the data from the first fragment, the third acknowledgment indicating that the endpoint service has completed storing the first fragment in a data store, wherein the first, second, and third acknowledgements identify the first fragment by the first timestamp.