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);
     }