[rocketmq] branch develop updated: [ISSUE #4644] Fix mqadmin deleteTopic bug when command exec on slave broker

[ji...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong 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 3a1d1a7e6 [ISSUE #4644] Fix mqadmin deleteTopic bug when command exec on slave broker
3a1d1a7e6 is described below

commit 3a1d1a7e60f9049fb7e5048a9f08cdcdbf996601
Author: JanWarlen <ja...@gmail.com>
AuthorDate: Fri Jul 22 09:06:45 2022 +0800

    [ISSUE #4644] Fix mqadmin deleteTopic bug when command exec on slave broker
---
 .../apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java
index 69e20606a..bdee33c52 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java
@@ -38,8 +38,8 @@ public class DeleteTopicSubCommand implements SubCommand {
         final String topic
     ) throws InterruptedException, MQBrokerException, RemotingException, MQClientException {
 
-        Set<String> brokerAddressSet = CommandUtil.fetchMasterAndSlaveAddrByClusterName(adminExt, clusterName);
-        adminExt.deleteTopicInBroker(brokerAddressSet, topic);
+        Set<String> masterBrokerAddressSet = CommandUtil.fetchMasterAddrByClusterName(adminExt, clusterName);
+        adminExt.deleteTopicInBroker(masterBrokerAddressSet, topic);
         System.out.printf("delete topic [%s] from cluster [%s] success.%n", topic, clusterName);
 
         Set<String> nameServerSet = null;