This is an automated email from the ASF dual-hosted git repository.
zhouxzhan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 32eb1d5557 [ISSUE #7068] Fix failed to create syncer topic when the
proxy was just started (#7076)
32eb1d5557 is described below
commit 32eb1d55570af81641a4a40d96ff5554329b93cb
Author: gaoyf <[email protected]>
AuthorDate: Tue Jul 25 15:26:20 2023 +0800
[ISSUE #7068] Fix failed to create syncer topic when the proxy was just
started (#7076)
---
.../org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java
b/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java
index f7d9b11ba8..c68859b288 100644
---
a/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java
+++
b/client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java
@@ -104,6 +104,7 @@ public class MQClientAPIFactory implements StartAndShutdown
{
rpcHook);
if (!mqClientAPIExt.updateNameServerAddressList()) {
+ mqClientAPIExt.fetchNameServerAddr();
this.scheduledExecutorService.scheduleAtFixedRate(
mqClientAPIExt::fetchNameServerAddr,
Duration.ofSeconds(10).toMillis(),