You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/05/10 01:59:04 UTC
[rocketmq] branch 5.0.0-beta updated: Fix the issue that DeleteTopicSubCommand does't call the correct deleteTopicInNameServer method. (#4269)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch 5.0.0-beta
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-beta by this push:
new 94f548351 Fix the issue that DeleteTopicSubCommand does't call the correct deleteTopicInNameServer method. (#4269)
94f548351 is described below
commit 94f54835103fd6cfe58cf39075189fed92331710
Author: sunxi92 <su...@163.com>
AuthorDate: Tue May 10 09:58:46 2022 +0800
Fix the issue that DeleteTopicSubCommand does't call the correct deleteTopicInNameServer method. (#4269)
---
.../org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 6cb3f18b9..69e20606a 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
@@ -48,7 +48,7 @@ public class DeleteTopicSubCommand implements SubCommand {
nameServerSet = new HashSet(Arrays.asList(ns));
}
- adminExt.deleteTopicInNameServer(nameServerSet, topic);
+ adminExt.deleteTopicInNameServer(nameServerSet, clusterName, topic);
System.out.printf("delete topic [%s] from NameServer success.%n", topic);
}