<div dir="ltr">Hi all,<div><br></div><div>RabbitMQ: 3.3.1</div><div>Erlang: 17</div><div><br></div><div>We have following situation:</div><div><br></div><div><ul><li><span style="font-size: 13px;">A queue contains a large amount of messages (5 million because the consumers are shutdown)</span></li><li><span style="font-size: 13px;">There's a constant  incoming message flow at a rate of ~2000 msg/s.</span></li><li><span style="font-size: 13px;">Messages are persistent though diskIO is far from being saturated.</span></li><li><span style="font-size: 13px;">Consumers have a prefetch value of 1000</span></li><li>We presume backpressure is applied to the producer in this situation (difficult to observe).</li></ul></div><div><br></div><div>What we observe is that out-rate settles to the in-rate, which I don't understand because:</div><div><ul><li><span style="font-size: 13px;">There a large amount of messages in the queue so plenty to consume.</span><br></li><li><span style="font-size: 13px;">We KNOW consumers are able to write at a much higher throughput even after bumping prefetch value.</span></li><li><span style="font-size: 13px;">When the queue is empty, in & outgoing rate is again 8000 msg/s</span></li></ul><div><span style="line-height: 17px;"><br></span></div><div><span style="line-height: 17px;">Any tips, leads why the consumption rate settles to the incoming rate in this situation?</span></div><div><span style="line-height: 17px;"><br></span></div><div><span style="line-height: 17px;">cheers,</span></div><div><span style="line-height: 17px;"><br></span></div><div><span style="line-height: 17px;">Jelle</span></div><div><span style="line-height: 17px;"><br></span></div><div><span style="line-height: 17px;"><br></span></div></div><div><br></div></div>