How do you handle backpressure and data loss prevention when a downstream consumer cannot keep up with an upstream data producer?
