If producer queue fills beyond N bytes, pause consumer until it recovers to less than M bytes (and provide warnings + metrics about consumer pause).
(need to consider behaviour on pausing consumer mid-frame - we are likely to get partial frames in that case)
If producer queue fills beyond N bytes, pause consumer until it recovers to less than M bytes (and provide warnings + metrics about consumer pause).
(need to consider behaviour on pausing consumer mid-frame - we are likely to get partial frames in that case)