HZL3151904214 commented on issue #1080:
URL: 
https://github.com/apache/rocketmq-client-go/issues/1080#issuecomment-1645084041

   the message queue lock expired, so consume 
later可能跟rebalance.lockMaxLiveTime默认值30s被我改成3s导致报错,但是理论上lockAll函数的实现也有问题吧,为啥UpdateLastConsumeTime和UpdateLastLockTime不一起进行更新?


-- 
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