feat: add mqadmin batch commands for deleting topics and subscription groups
维护者通常 1 天内回复
评估
调研方向
Start from the existing client calls in MQClientAPIImpl (around line 22) and the broker handlers AdminBrokerProcessor#deleteTopicList (line 813) and #deleteSubscriptionGroupList (line 1839), which the issue says already exist. Then look at how the current mqadmin commands wire into those client methods and copy that pattern for two new batch commands. Done means both commands run against a broker, accept lists of names, and report results.
由索引模型根据 Issue 内容生成。
描述
功能说明：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 ...
- 主要语言
- Java
- 星标
- 22.7k
- 派生
- 12k
- 平均合并
- 4 天 20 小时
- 30 天内合并 PR
- 11
环境准备
- 没有 Dockerfile 或 Docker Compose 文件
- 有 Pull Request 模板
- 阅读贡献指南
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
apache/rocketmq 的其他 Issue
-
[Bug] RemotingHelper.connect swaps the socket send and receive buffer configuration可能已有人在做 @amalsaidov 今天认领。 未关闭
难度 2/5 1-3 小时 新手友好度 82/100
维护者通常 1 天内回复
-
CompressionType.of fails under the Turkish locale可能已有人在做 @sharanggupta 今天认领。 未关闭
难度 2/5 1-3 小时 新手友好度 83/100
维护者通常 1 天内回复
-
[rocketmq-client-python] TransactionMQProducer allocates an unused producer during initialization未关闭
难度 2/5 1-3 小时 新手友好度 82/100
维护者通常 1 天内回复
-
[Bug] notifyMasterOnline aborts the long-polling wake-up with a NullPointerException when an arrival drains a bucket first可能已有人在做 @iloveeyjafjalla 于 29 天前认领。 未关闭
难度 2/5 1-3 小时 新手友好度 82/100
apache/rocketmq#11441 · 1 条评论 ·
维护者通常 1 天内回复
-
[Enhancement] FilterFactory duplicate-registration and unregister semantics lack tests可能已有人在做 @chennaji9 于 34 天前认领。 未关闭
难度 2/5 1-3 小时 新手友好度 84/100
apache/rocketmq#11340 · 2 条评论 ·
维护者通常 1 天内回复
相似的 Issue
-
bug emitter:client:csharp
难度 2/5 1-3 小时 新手友好度 84/100
microsoft/typespec#12572 · 1 条评论 · 1 个 reaction ·
维护者通常 1 天内回复
-
GCC 15.2: -Wcast-qual warning - cast discards const qualifier from pointer target type (H5trace.c)未关闭
难度 2/5 1-3 小时 新手友好度 73/100
维护者通常 1 天内回复
-
needs-area-label
难度 2/5 1-3 小时 新手友好度 78/100
维护者通常 2 天内回复
-
area/ai area/backend component/zeebe kind/task
难度 2/5 1-3 小时 新手友好度 68/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 72/100
spAnser/reacharound#38 ·