When stream consumers lag producers, the Message queue (broker) will grow without bound. Kleppman identifies one of three remedies:

  1. the producer can drop messages from the queue;
  2. the producer can buffer the messages to an external store; or
  3. the consumers can apply backpressure to the producer.