NAND86 commented on issue #580:
URL: 
https://github.com/apache/rocketmq-client-go/issues/580#issuecomment-755042659


   原因已经在 #587 说明清楚。
   
这个问题主要是异常测试中同一消费者组内的顺序消费者频繁启停,导致一直存活的客户端一直新增队列删除队列。协程一直泄露,但是topic又一直没消息,所有协程都卡在consumeMessageOrderly
 内部 takeMessages的for循环中。
   
   所以如果takeMessages的for循环一段时间拿不到消息最好退出循环吧,否则解决了协程泄露的问题,仍然会有一个协程卡在for中。


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

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


Reply via email to