You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/10/27 03:59:02 UTC

[GitHub] [rocketmq] Cczzzz commented on issue #3434: BUG ： Consumers start slowly

Cczzzz commented on issue #3434:
URL: https://github.com/apache/rocketmq/issues/3434#issuecomment-952516089


   修复方式 
   修改 MQClientInstance#sendHeartbeatToAllBrokerWithLock 方法 ，返回值改成 boolean ，表示是否正常发送了心跳任务。如果发送失败，进行定时重试
   
   或者 
    tryLock 
    改成
    tryLock(long time, TimeUnit unit) throws InterruptedException;
   允许传入最大的等待时间。rebalance 线程可以被堵塞吗？
   
   
   


-- 
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: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org