| CPC H04L 47/32 (2013.01) | 20 Claims |
|
1. A method comprising:
receiving, at a data consumer comprising a first computing device, a data stream from a data producer on a second computing device, the data stream comprising a plurality of data records;
measuring, with the data consumer, a propagation delay in the data consumer causing backpressure on the data stream, the propagation delay comprising a processing delay in the data consumer and representing a difference in a first rate at which the data producer produces the plurality of data records and a second rate at which the data consumer consumes the plurality of data records;
determining, with the data consumer, a maximum tolerated delay;
determining, with the data consumer, a threshold delay representing a delay value that triggers calculation of a drop rate;
calculating, with the data consumer, the drop rate based on the backpressure delay, the maximum delay, and the threshold delay, the drop rate representing a percentage of the data records;
selecting, with the data consumer, a drop strategy; and
discarding, with the data consumer, one or more data records from the data stream based on the drop rate, according to the drop strategy.
|