5、RocketMQ消息消費重試

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

>>阅读原文<<