请教下使用Apache RocketMQ中mqadmin deleteTopic 命令只能在broker主机上执行吗？发现在非broker主机执行这个命令报错Caused by: org.apache.rocketmq.client.exception.MQClientException: CODE: 1 DESC: Can’t modify topic or subscription group from slave broker, please execute it from master broker？
请教下使用Apache RocketMQ中mqadmin deleteTopic 命令只能在？[阿里云消息队列MQ]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
这个应该是代码写错了。
org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl#deleteTopic
这个方法里，用的是Set brokerAddressSet = CommandUtil.fetchMasterAndSlaveAddrByClusterName(this.defaultMQAdminExt, clusterName);获取主和从节点的address，应该是获取主节点的adderss。用fetchMasterAddrByClusterName。