You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "Metastarx (via GitHub)" <gi...@apache.org> on 2026/10/18 11:57:41 UTC
[PR] Add lite topic listing admin API and mqadmin command [rocketmq]
Metastarx opened a new pull request, #11451:
URL: https://github.com/apache/rocketmq/pull/11451
### Which Issue(s) This PR Fixes
- Fixes #11450
### Brief Description
RocketMQ currently exposes an aggregate lite topic count plus single-topic and single-client lookups, but there is no broker-side way to enumerate the dynamically created lite topics under a parent topic. This change adds a GET_LITE_TOPIC_LIST request with a required parent topic, an optional name prefix, and a bounded maxCount, and the broker returns each lite topic's offsets, last update time, subscriber count, and sharding ownership together with a hasMore truncation flag. The new client, admin, and DefaultMQAdminExt methods are wired through a getLiteTopicList mqadmin command (also available as listLiteTopic) that prints one table row per broker, and the LMQ guide documents the command and sample output.
### How Did You Test This Change?
`mvn test -pl broker,client,remoting,tools` - passed (Tests run: 172, Failures: 0, Errors: 0, Skipped: 5)
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] Add lite topic listing admin API and mqadmin command [rocketmq]
Posted by "codecov-commenter (via GitHub)" <gi...@apache.org>.
codecov-commenter commented on PR #11451:
URL: https://github.com/apache/rocketmq/pull/11451#issuecomment-6249893374
## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/11451?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) Report
:x: Patch coverage is `75.14451%` with `43 lines` in your changes missing coverage. Please review.
:white_check_mark: Project coverage is 49.98%. Comparing base ([`5d68880`](https://app.codecov.io/gh/apache/rocketmq/commit/5d68880cbdfa5c6d87b5681c5eb3684df0e18ef8?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)) to head ([`6bac291`](https://app.codecov.io/gh/apache/rocketmq/commit/6bac291eebfb72ecd38e48a74006847e718a67d5?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)).
| [Files with missing lines](https://app.codecov.io/gh/apache/rocketmq/pull/11451?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Patch % | Lines |
|---|---|---|
| [...tools/command/lite/GetLiteTopicListSubCommand.java](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&filepath=tools%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Ftools%2Fcommand%2Flite%2FGetLiteTopicListSubCommand.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-dG9vbHMvc3JjL21haW4vamF2YS9vcmcvYXBhY2hlL3JvY2tldG1xL3Rvb2xzL2NvbW1hbmQvbGl0ZS9HZXRMaXRlVG9waWNMaXN0U3ViQ29tbWFuZC5qYXZh) | 50.81% | [29 Missing and 1 partial :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...ocketmq/broker/processor/LiteManagerProcessor.java](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&filepath=broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fbroker%2Fprocessor%2FLiteManagerProcessor.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvcHJvY2Vzc29yL0xpdGVNYW5hZ2VyUHJvY2Vzc29yLmphdmE=) | 89.09% | [2 Missing and 4 partials :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...g/apache/rocketmq/client/impl/MQClientAPIImpl.java](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&filepath=client%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fclient%2Fimpl%2FMQClientAPIImpl.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-Y2xpZW50L3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9jbGllbnQvaW1wbC9NUUNsaWVudEFQSUltcGwuamF2YQ==) | 0.00% | [5 Missing :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...apache/rocketmq/tools/admin/DefaultMQAdminExt.java](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&filepath=tools%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Ftools%2Fadmin%2FDefaultMQAdminExt.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-dG9vbHMvc3JjL21haW4vamF2YS9vcmcvYXBhY2hlL3JvY2tldG1xL3Rvb2xzL2FkbWluL0RlZmF1bHRNUUFkbWluRXh0LmphdmE=) | 0.00% | [1 Missing :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...he/rocketmq/tools/admin/DefaultMQAdminExtImpl.java](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&filepath=tools%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Ftools%2Fadmin%2FDefaultMQAdminExtImpl.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-dG9vbHMvc3JjL21haW4vamF2YS9vcmcvYXBhY2hlL3JvY2tldG1xL3Rvb2xzL2FkbWluL0RlZmF1bHRNUUFkbWluRXh0SW1wbC5qYXZh) | 0.00% | [1 Missing :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/11451?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
<details><summary>Additional details and impacted files</summary>
```diff
@@ Coverage Diff @@
## develop #11451 +/- ##
=============================================
+ Coverage 49.76% 49.98% +0.21%
- Complexity 14377 14527 +150
=============================================
Files 1390 1393 +3
Lines 103262 103435 +173
Branches 13504 13522 +18
=============================================
+ Hits 51392 51698 +306
+ Misses 45681 45529 -152
- Partials 6189 6208 +19
```
</details>
[:umbrella: View full report in Codecov by Harness](https://app.codecov.io/gh/apache/rocketmq/pull/11451?dropdown=coverage&src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
:loudspeaker: Have feedback on the report? [Share it here](https://about.codecov.io/codecov-pr-comment-feedback/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
<details><summary> :rocket: New features to boost your workflow: </summary>
- :snowflake: [Test Analytics](https://docs.codecov.com/docs/test-analytics): Detect flaky tests, report on failures, and find test suite problems.
</details>
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] Add lite topic listing admin API and mqadmin command [rocketmq]
Posted by "Metastarx (via GitHub)" <gi...@apache.org>.
Metastarx commented on PR #11451:
URL: https://github.com/apache/rocketmq/pull/11451#issuecomment-6339161719
Addressed in bb28e1bc95ad.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org