diff --git a/lib/mq_client_api.js b/lib/mq_client_api.js
index c3ae509..f70ce39 100644
--- a/lib/mq_client_api.js
+++ b/lib/mq_client_api.js
@@ -482,6 +482,7 @@ class MQClientAPI extends RemotingClient {
     const responseHeader = response.decodeCommandCustomHeader();
     const messageQueue = new MessageQueue(msg.topic, brokerName, responseHeader.queueId);
     messageQueue.topic = this._clearProjectGroup(messageQueue.topic);
+    messageQueue.brokerAddr = brokerAddr;
 
     return {
       sendStatus,