[Feature🚀] Implement BrokerConsumeStats command in rocketmq-admin-core #6278
Description
Feature Description
Add support for BrokerConsumeStats command to query broker consumption statistics in the rocketmq-admin-core crate.
Problem/Motivation
Currently, rocketmq-rust lacks the broker consumption statistics command that exists in Java RocketMQ tools. This command is essential for monitoring and troubleshooting consumption performance issues by showing detailed statistics about message consumption on the broker side.
Proposed Solution
Implement the BrokerConsumeStats command in rocketmq-admin-core under a new broker_commands module, mirroring the functionality of Java's BrokerConsumeStatsSubCommand.
Key features to implement:
- Query consumption statistics from broker
- Display consumer group consumption details
- Show message accumulation information
- Support filtering by consumer group
The implementation should be placed in:
rocketmq-tools/rocketmq-admin/rocketmq-admin-core/src/commands/broker_commands/
Alternatives
Could integrate this into existing consumer commands, but separating broker-specific commands provides better organization and aligns with Java implementation structure.
Additional Context
- Java Reference: https://github.com/apache/rocketmq/blob/develop/tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java
- Target crate:
rocketmq-admin-core - Related modules: broker_commands (new module to be created)