Skip to content

Commit 449b083

Browse files
committed
Fix the issue that DeleteTopicSubCommand does't call the correct deleteTopicInNameServer method.
1 parent d6a53f9 commit 449b083

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public static void deleteTopic(final DefaultMQAdminExt adminExt,
4848
nameServerSet = new HashSet(Arrays.asList(ns));
4949
}
5050

51-
adminExt.deleteTopicInNameServer(nameServerSet, topic);
51+
adminExt.deleteTopicInNameServer(nameServerSet, clusterName, topic);
5252
System.out.printf("delete topic [%s] from NameServer success.%n", topic);
5353
}
5454

0 commit comments

Comments
 (0)