1782935682 commented on issue #7884: URL: https://github.com/apache/rocketmq/issues/7884#issuecomment-1979978791
> How do you create and delete topics? dashboard or mqadmin or sdk？ I want to try to reproduce this issue 1.create with dashboard，create topic on cluster <img width="1218" alt="image" src="https://github.com/apache/rocketmq/assets/49970811/54f71e3e-a32f-4827-9210-2f32f761a551";> 2.use sdk , delete topic in one broker org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl#deleteTopicInBroker; DefaultMQAdminExt mqAdminExt = new DefaultMQAdminExt(new AclClientRPCHook(new SessionCredentials("ak", "sk")), 20000); String name = UUID.randomUUID().toString(); mqAdminExt.setInstanceName(name); mqAdminExt.setNamesrvAddr(DEFAULT_NAMESRVADDR); mqAdminExt.start(); System.out.println("delete before"); System.out.println("topicRouter" + ": " + JSON.toJSONString(mqAdminExt.examineTopicRouteInfo(TOPIC), true)); mqAdminExt.deleteTopicInBroker(Collections.singleton(broker01), TOPIC); System.out.println("delete after"); System.out.println("topicRouter" + ": " + JSON.toJSONString(mqAdminExt.examineTopicRouteInfo(TOPIC), true)); -- 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]
