When stream consumers lag producers, the Message queue (broker) will grow without bound. Kleppman identifies one of three remedies:
- the producer can drop messages from the queue;
- the producer can buffer the messages to an external store; or
- the consumers can apply backpressure to the producer.