Metastarx opened a new issue, #11443: URL: https://github.com/apache/rocketmq/issues/11443
功能说明:The broker already implements batch deletion of topics and subscription groups (AdminBrokerProcessor#deleteTopicList and AdminBrokerProcessor#deleteSubscriptionGroupList at broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java:813 and :1839, request codes DELETE_TOPIC_IN_BROKER_LIST=5002 and DELETE_SUBSCRIPTION_GROUP_LIST=5003 in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java:315-316, bodies DeleteTopicListRequestBody and DeleteSubscriptionGroupListRequestBody, dedup plus a RateLimiter driven by BrokerConfig#batchDeleteTopicMaxRate/#batchDeleteSubscriptionGroupMaxRate at common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java:386/392, one-shot persist, and clean-offset handling for lite groups), and the client already exposes both calls (client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java:22 ... -- 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]
