JanWarlen opened a new pull request, #4652: URL: https://github.com/apache/rocketmq/pull/4652
**Make sure set the target branch to `develop`**
## What is the purpose of the change
mqadmin deleteTopic only request master brokers
## Brief changelog
`org.apache.rocketmq.tools.command.topic.DeleteTopicSubCommand#deleteTopic`
-- Set<String> brokerAddressSet =
CommandUtil.fetchMasterAndSlaveAddrByClusterName(adminExt, clusterName);
-- adminExt.deleteTopicInBroker(brokerAddressSet, topic);
++ Set<String> masterBrokerAddressSet =
CommandUtil.fetchMasterAddrByClusterName(adminExt, clusterName);
++ adminExt.deleteTopicInBroker(masterBrokerAddressSet, topic);
## Verifying this change
I cannot exec `mvn clean package -DskipTests` on branch `4.9.x`,so I did
same change on branch `release-4.9.4`(didn't commit).
And tested on my 1m-2s-sync cluster.
```shell
[root@master bin]# ./mqadmin topicList -n master:9876 -c
#Cluster Name #Topic
#Consumer Group
DefaultCluster SCHEDULE_TOPIC_XXXX
DefaultCluster RMQ_SYS_TRANS_HALF_TOPIC
DefaultCluster DefaultCluster_REPLY_TOPIC
DefaultCluster BenchmarkTest
DefaultCluster OFFSET_MOVED_EVENT
DefaultCluster broker-a
DefaultCluster TBW102
DefaultCluster SELF_TEST_TOPIC
DefaultCluster DefaultCluster
[root@master bin]# date
Thu Jul 21 07:11:08 EDT 2022
[root@master bin]# ./mqadmin updateTopic -n master:9876 -c DefaultCluster -t
test_topic
create topic to 192.168.125.201:10911 success.
TopicConfig [topicName=test_topic, readQueueNums=8, writeQueueNums=8,
perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]
[root@master bin]# date
Thu Jul 21 07:11:17 EDT 2022
[root@master bin]# ./mqadmin topicList -n master:9876 -c
#Cluster Name #Topic
#Consumer Group
DefaultCluster SCHEDULE_TOPIC_XXXX
DefaultCluster RMQ_SYS_TRANS_HALF_TOPIC
DefaultCluster DefaultCluster_REPLY_TOPIC
DefaultCluster test_topic
DefaultCluster BenchmarkTest
DefaultCluster OFFSET_MOVED_EVENT
DefaultCluster broker-a
DefaultCluster TBW102
DefaultCluster SELF_TEST_TOPIC
DefaultCluster DefaultCluster
[root@master bin]# ./mqadmin deleteTopic -n 'master:9876' -c DefaultCluster
-t test_topic
brokerAddressSet:[192.168.125.201:10911]
org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.deleteTopicInBroker:192.168.125.201:10911
delete topic [test_topic] from cluster [DefaultCluster] success.
delete topic [test_topic] from NameServer success.
[root@master bin]# date
Thu Jul 21 07:11:33 EDT 2022
[root@master bin]# ./mqadmin topicList -n master:9876 -c
#Cluster Name #Topic
#Consumer Group
DefaultCluster SCHEDULE_TOPIC_XXXX
DefaultCluster RMQ_SYS_TRANS_HALF_TOPIC
DefaultCluster DefaultCluster_REPLY_TOPIC
DefaultCluster BenchmarkTest
DefaultCluster OFFSET_MOVED_EVENT
DefaultCluster broker-a
DefaultCluster TBW102
DefaultCluster SELF_TEST_TOPIC
DefaultCluster DefaultCluster
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
