feat: add mqadmin batch commands for deleting topics and subscription groups

Đang mở
  • Có gì không ổn?
#11,443 1 bình luận 0 reaction 0 người được giao Xem trên GitHub

Maintainer thường phản hồi trong vòng 1 ngày

@Metastarx đang làm issue này rồi.

Từ ngày 15/10/2026.

  • #11444 của @Metastarx — đang mở

Đánh giá

Độ khó
3/5
Thời gian dự kiến
Nửa ngày
Mức phù hợp với người mới
62/100
Loại issue
Tính năng
Độ rõ ràng
Khá rõ ràng
Mức độ hoạt động
Sôi nổi
Công nghệ
java
Lĩnh vực
cli

Hướng nghiên cứu

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.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

功能说明：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 ...

Ngôn ngữ chính
Java
Star
22.7k
Fork
12k
Merge trung bình
4 ngày 20 giờ
Pull request đã merge (30 ngày)
11

Chuẩn bị môi trường

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của apache/rocketmq

Tất cả issue của apache/rocketmq

Issue tương tự

Thêm issue về Java

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.