We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3fe7535 commit 15af63eCopy full SHA for 15af63e
client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -223,7 +223,7 @@ public void start() throws MQClientException {
223
this.serviceState = ServiceState.START_FAILED;
224
// If not specified,looking address from name server
225
if (null == this.clientConfig.getNamesrvAddr()) {
226
- this.clientConfig.setNamesrvAddr(this.mQClientAPIImpl.fetchNameServerAddr());
+ this.mQClientAPIImpl.fetchNameServerAddr();
227
}
228
// Start request-response channel
229
this.mQClientAPIImpl.start();
0 commit comments