徐老师好，在MillWheel中为了保证消息处理至少一次的语义，Computation的每条消息在发送之后都需要应答，收不到应答就会不断重试。String Production的做法是，下游Computation收到消息后存起来，然后立即应答上游的Computation。Weak Production的做法是，不保存消息，不保存消息就必须等整个链路处理完再逐层应答，链路越长，遇到故障的可能性越大，故障会导致消息从头消费，整个系统的延迟就变大了。解决方法就是Computation在发出消息一段时间后收不到应答，就把消息存起来，并应答上游的Computation。这样如果下游链路出问题，只需要从当前的Computation开始重试，而不用从头开始。