请教下使用Apache RocketMQ中mqadmin deleteTopic 命令只能在?
这个应该是代码写错了。org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl#deleteTopic这个方法里,用的是Set brokerAddressSet = CommandUtil.fetchMasterAndSlaveAddrByClusterName(this.defaultMQAdminExt, clusterName);获取主和从节点的address,应该是获取主节点的adderss。用fetchMasterAddrByClusterName。
赞0
踩0