Many messaging systems are in-balanced and can send faster than they can receive. NATS has this ability to do this and was reporting a slow consumer state that was not being realized. Adding in the original flush alleviated the problem, but at a huge performance cost for throughput since it introduced a sync ack effectively for each send. This change balances the publishing rate with the subscriber rate by watching for spreads between sent and received messages and bytes.
Many messaging systems are in-balanced and can send faster than they can receive. NATS has this ability to do this and was reporting a slow consumer state that was not being realized. Adding in the original flush alleviated the problem, but at a huge performance cost for throughput since it introduced a sync ack effectively for each send. This change balances the publishing rate with the subscriber rate by watching for spreads between sent and received messages and bytes.