從 RocketMq-Console-Ng 查看 topic 消費情況,sitVasGroup 這個消費組確實沒有消費到 sitServicePayTopic 的消息。
看到同壹個消費者 Group ID(sitVasGroup)下有兩個 Consumer 實例 (10.3.200.98@wxPayNotifyConsumer 和 10.3.200.98@companyConsumer )。
和開發人員確認,兩個 Consumer 實例訂閱的 topic 不壹致,10.3.200.98@companyConsumer 訂閱的 topic 是 testUsercenterTopic,而 10.3.200.98@wxPayNotifyConsumer 訂閱的 topic 是 sitServicePayTopic。
原因分析:
使用新的消費組 testVasPayGroup 訂閱 topic sitServicePayTopic 的消息,問題解決。
參考: