advanced

Backpressure

Контролируйте producer rate, queue depth, consumer concurrency, prefetch, lag и load shedding, чтобы messaging buffers не скрывали overload.

Backpressure сигнализирует, что downstream не успевает — растущая queue depth, consumer lag или disk broker. Ответы: замедлить producers, limit prefetch, scale consumers, shed load или reject publishes при превышении buffers.

Компромисс: buffering сглаживает spikes, но скрывает overload до катастрофы; ранний shedding защищает систему, но отбрасывает work.

На интервью: диагностика линейно растущего lag; scale consumers vs throttle producers.

Типовые ошибки: infinite buffer как безлимитная capacity; scale consumers выше partition count; нет alerts на lag SLO.

Чеклист:

  • Lag и depth SLOs с alerts.
  • Cap prefetch и in-flight per consumer.
  • Producer throttling или circuit breaking.
  • Load test при sustained overload.