feat: add mqadmin batch commands for deleting topics and subscription groups
Los mantenedores suelen responder en 1 día
Evaluación
- Dificultad
- 3/5
- Tiempo estimado
- Medio día
- Aptitud para principiantes
- 62/100
Línea de trabajo
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.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
功能说明：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 ...
- Lenguaje dominante
- Java
- Estrellas
- 22.7k
- Forks
- 12k
- Merge medio
- 4 d 20 h
- PR fusionados (30 d)
- 11
Preparar el entorno
- Sin Dockerfile ni archivo de Docker Compose
- Tiene una plantilla de pull request
- Leer la guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/rocketmq
-
[Bug] RemotingHelper.connect swaps the socket send and receive buffer configurationPosiblemente ocupada @amalsaidov la tomó hoy. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
Los mantenedores suelen responder en 1 día
-
CompressionType.of fails under the Turkish localePosiblemente ocupada @sharanggupta la tomó hoy. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 83/100
Los mantenedores suelen responder en 1 día
-
[rocketmq-client-python] TransactionMQProducer allocates an unused producer during initializationAbierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
Los mantenedores suelen responder en 1 día
-
[Bug] notifyMasterOnline aborts the long-polling wake-up with a NullPointerException when an arrival drains a bucket firstPosiblemente ocupada @iloveeyjafjalla la tomó hace 29 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
apache/rocketmq#11441 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
[Enhancement] FilterFactory duplicate-registration and unregister semantics lack testsPosiblemente ocupada @chennaji9 la tomó hace 34 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
apache/rocketmq#11340 · 2 comentarios ·
Los mantenedores suelen responder en 1 día
Todos los issues de apache/rocketmq
Issues similares
-
bug emitter:client:csharp
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
microsoft/typespec#12572 · 1 comentario · 1 reacción ·
Los mantenedores suelen responder en 1 día
-
GCC 15.2: -Wcast-qual warning - cast discards const qualifier from pointer target type (H5trace.c)Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 73/100
Los mantenedores suelen responder en 1 día
-
needs-area-label
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
Los mantenedores suelen responder en 2 días
-
area/ai area/backend component/zeebe kind/task
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
spAnser/reacharound#38 ·