cserwen commented on issue #3787:
URL: https://github.com/apache/rocketmq/issues/3787#issuecomment-1035998737


   > @cserwen if we set the corresponding ack message timeout > 10s, that is 
longer than ck message timeout. Is this problem will be solved? BTW, i don't 
understand the adjust - 1500, do u know in which case it works?
   
   @lizhiboo  
   设置这个ack消息的超时时间超过10s,我不太明白这个怎么避免这个问题的发生:joy:
   
   关于这个 - 1.5s的判断,在添加ack消息时会进行判断, 
如果ack消息对应的ck消息在buffer中待的时间超过了`brokerController.getBrokerConfig().getPopCkStayBufferTime()
 - 1500`,这个时间,ack消息就必须写入延时Topic中,即这个时候ck消息不能被ack了,等reviveService去处理这部分ack消息。 
我认为这1.5s应该是为了不想要加锁,提前禁止ck消息被ack?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to