Backpressure
Quando o consumidor é mais lento que o produtor — estratégias para impedir que os buffers de entrada cresçam sem limite e derrubem o sistema.
Soluções: drop (descartar mensagens), buffer (esperar até um limite X), block (pausar o produtor), credit-based (o consumidor avisa quanto consegue processar). O TCP faz algo do tipo credit-based por meio do tamanho da janela. O Reactive Streams (RxJava, Project Reactor, Akka Streams) padroniza isso para uso in-process.
Armadilha clássica: buffer sem limite = nenhum backpressure = OOM sob carga. O Kafka usa o commit de offset do consumidor como sinal natural de backpressure.