rocketmq 暫停


當調用DefaultMQPushConsumer的suspend的方法時,會暫停發送從broker中獲取消息的命令,此時消息還存在broker(消息隊列服務器)的某個隊列中,

又因為一個隊列只能對應一個消費組內的一個消費者,所以這個隊列中的消息只能發送給固定的消費者,導致這個消息一直不會被其他消費者消費,

除非調用resume方法進行恢復。或者將暫停的消費者kill,那樣的話broker就不會再從NameServer中拿到那個被kill的消費者的信息,那么存在broker中

的消息就會發送給其他存活的消費者來進行消費。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM