Backpressure

Network buffers, credit-based flow control, chaining, async I/O — what a slow downstream call does to everything upstream

Flink propagates slowness backward by design. GatewayMeter enriches records with a negotiated price from the billing service; when that service takes two seconds per call the whole pipeline slows, Kafka lag climbs and checkpoints time out. You read backpressure off the metrics, then relieve it with async I/O, capacity and unaligned checkpoints.

Estimated time: 75 minutes

Stuck on something? The AI tutor sees this lecture—just ask.