Closed 847850277 closed 1 month ago
The recent code changes enhance the AdminBrokerProcessor
to better manage consumer-related topic queries by integrating server configuration. A new method to query topics by consumer group is added, improving offset management. This functionality allows for more dynamic responses to administrative requests, ultimately enhancing the RocketMQ broker's capabilities.
Files | Change Summary |
---|---|
rocketmq-broker/src/broker_runtime.rs |
Added server_config parameter to AdminBrokerProcessor::new for enhanced configuration. |
rocketmq-broker/src/offset/manager/consumer_offset_manager.rs |
Introduced which_topic_by_consumer method to retrieve topics by consumer group. |
rocketmq-broker/src/processor/admin_broker_processor.rs |
Updated AdminBrokerProcessor to handle server configuration and added request handling for topic queries by consumer. |
rocketmq-broker/src/processor/admin_broker_processor/topic_request_handler.rs |
Added query_topics_by_consumer async function to manage topic queries for specific consumers. |
rocketmq-remoting/src/protocol/header.rs |
Introduced new module query_topics_by_consumer_request_header for handling related requests. |
rocketmq-remoting/src/protocol/header/query_topics_by_consumer_request_header.rs |
Defined QueryTopicsByConsumerRequestHeader struct for consumer topic query requests. |
sequenceDiagram
participant AdminBrokerProcessor
participant TopicRequestHandler
participant ConsumerOffsetManager
AdminBrokerProcessor->>TopicRequestHandler: Request to query topics by consumer
TopicRequestHandler->>ConsumerOffsetManager: Fetch topics for consumer group
ConsumerOffsetManager-->>TopicRequestHandler: Return list of topics
TopicRequestHandler-->>AdminBrokerProcessor: Respond with topics list
Objective | Addressed | Explanation |
---|---|---|
Support AdminBrokerProcessor query_topics_by_consumer (#892) | ✅ | |
Enhance AdminBrokerProcessor for server configuration management | ✅ |
🐰 In the fields I hop and play,
New queries bloom, come what may!
Topics found by groups so fine,
Server secrets now align.
Cheers to code that leaps and bounds,
In the broker, joy abounds! 🎉
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 58 lines
in your changes missing coverage. Please review.
Project coverage is 24.38%. Comparing base (
9568572
) to head (5c3dfef
). Report is 1 commits behind head on main.
: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 #892
Brief Description
How Did You Test This Change?
Summary by CodeRabbit
New Features
AdminBrokerProcessor
with server configuration management.ConsumerOffsetManager
.TopicRequestHandler
.Documentation