五、RocketMQ消息消費重試

1.consumer prepare：消費者啓動，訂閱正常的topic（包含tag）以及一個%RETRY%consumergroup的topic，並將訂閱關係（SubscriptionData）以心跳方式上傳給broker。consumer會與所有的broker建立連接發送心跳。 2.consumer經過RebalanceService.doRebalance後，開始pull message。當拉

>>阅读原文<<