需要面试准备
生产者和消费者之间的流式管线靠基于信用的背压(credit-based backpressure)粘合:消费者按自己能吸收的能力发布 credit,生产者每次发送扣掉对应额度,消费者完成处理后通过 ack 把 credit 归还回来。这套流控机制就是 TCP 接收窗口、Reactive Streams request(n)、Akka Streams demand 信号背后的同一套东西——它让一个快生产者不会把慢消费者冲垮,又不至于直接丢数据。本题要你回放一段事件流,跑这套协议,输出一份逐事件的状态 trace,下游可观测服务可以拿去画图。