feat: expand Admin service with control-plane RPCs - #113
Merged
lizhimins merged 1 commit intoJul 29, 2026
Conversation
Extend the gRPC Admin service from a single ChangeLogLevel RPC to a full control-plane surface for cluster administration and diagnostics, adding 15 RPCs: DescribeTopicStatus, ListSubscription, DescribeSubscription, DeleteSubscription, DescribeGroupAccumulation, ListConsumerConnection, ResetGroupOffset, QueryMessage, PrintThreadStackTrace, VerifyMessage, AdminSendMessage, GetConsumerRunningInfo, GetTopicRoute, QueryTimeSpan and GetProxyRuntimeStats. All request/response messages reuse existing types from definition.proto (Resource, Status, FilterExpression, MessageQueue, Message, SystemProperties, MessageType) and are documented with inline comments.
|
这是来自QQ邮箱的自动回复邮件。
您好，请您放心您的邮件我已经收到。我将在看过邮件后，尽快给您回复。
|
3 tasks
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Today the gRPC
Adminservice only exposes a singleChangeLogLevelRPC, while all cluster administration and diagnostics still go through the legacy Remoting binary protocol. This PR expandsadmin.protointo a full control-plane surface so that management operations can share the same gRPC + Protobuf stack as the data plane, lowering the bar for multi-language admin tooling.Adds 15 RPCs to
service Admin:DescribeTopicStatus,GetTopicRouteListSubscription,DescribeSubscription,DeleteSubscriptionDescribeGroupAccumulation,QueryTimeSpan,ResetGroupOffsetQueryMessage,AdminSendMessageListConsumerConnection,GetConsumerRunningInfo,PrintThreadStackTrace,VerifyMessageGetProxyRuntimeStatsDesign notes:
definition.prototypes (Resource,Status,FilterExpression,MessageQueue,Message,SystemProperties,MessageType).Points for discussion
MessageModelenum (CLUSTERING / BROADCASTING) local toadmin.protofor subscription/consumer diagnostics. ChangeLog item 8 removedMessageModelfrom the data plane; reviewers may prefer a different name or placement.GetProxyRuntimeStatsis named after the proxy deployment; open to renaming (e.g.GetRuntimeStats) if a broker-embedded gateway is preferred.Verification
bazel build //:rocketmq_v2_proto— passesbazel build //java:rocketmq-proto— passes, generatesAdminGrpcstubs