Closed 847850277 closed 1 week ago
This pull request introduces a new feature to the AdminBrokerProcessor
by adding support for handling the GetAllConsumerOffset
request. It implements an asynchronous method in the ConsumerRequestHandler
that retrieves all consumer offsets managed by the broker. The changes enhance the ability to manage and monitor consumer-related data effectively.
Files | Change Summary |
---|---|
rocketmq-broker/src/processor/admin_broker_processor.rs |
Added handling for RequestCode::GetAllConsumerOffset in AdminBrokerProcessor . |
rocketmq-broker/src/processor/admin_broker_processor/consumer_request_handler.rs |
Introduced get_all_consumer_offset method to retrieve consumer offsets and construct appropriate response. |
Objective | Addressed | Explanation |
---|---|---|
Support AdminBrokerProcessor get_all_consumer_offset (#969) | ✅ |
feature
In the meadow where bunnies play,
New offsets bloom, bright as day.
With each request, we hop and cheer,
For consumer data now draws near!
A leap for features, a joyful dance,
In RocketMQ, we take our chance! 🐇✨
[!TIP]
New features
Walkthrough comment now includes: - Possibly related PRs: A list of potentially related PRs to help you recall past context. - Suggested labels: CodeRabbit can now suggest labels by learning from your past PRs. You can also provide custom labeling instructions in the UI or configuration file. Notes: - Please share any feedback in the [discussion post](https://discordapp.com/channels/1134356397673414807/1282535539299323995) on our Discord. - Possibly related PRs, automatic label suggestions based on past PRs, learnings, and possibly related issues require data opt-in (enabled by default).
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
🚀Thanks for your contribution🎉. CodeRabbit(AI) will review your code first🔥
Attention: Patch coverage is 0%
with 20 lines
in your changes missing coverage. Please review.
Project coverage is 21.24%. Comparing base (
27debb7
) to head (e03f480
). Report is 1 commits behind head on main.
Files with missing lines | Patch % | Lines |
---|---|---|
...admin_broker_processor/consumer_request_handler.rs | 0.00% | 17 Missing :warning: |
...tmq-broker/src/processor/admin_broker_processor.rs | 0.00% | 3 Missing :warning: |
:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.
Which Issue(s) This PR Fixes(Closes)
Fixes #969
Brief Description
How Did You Test This Change?
Summary by CodeRabbit
New Features
GetAllConsumerOffset
in the admin broker processor.Bug Fixes