Skip to content

[ISSUE #381 #402] Add proxy fallback for gRPC consumer stats and request codes 106/206/208#418

Closed
itxaiohanglover wants to merge 1 commit into
apache:masterfrom
itxaiohanglover:fix/grpc-consumer-latency-proxy
Closed

[ISSUE #381 #402] Add proxy fallback for gRPC consumer stats and request codes 106/206/208#418
itxaiohanglover wants to merge 1 commit into
apache:masterfrom
itxaiohanglover:fix/grpc-consumer-latency-proxy

Conversation

@itxaiohanglover

Copy link
Copy Markdown

Fixes #381, fixes #402. Add proxy fallback for examineConsumeStats (208), getBrokerClusterInfo (106), and getAllTopicListFromNameServer (206) when standard mqAdminExt methods fail in proxy mode.

…ats and request codes 106/206/208

When dashboard connects to RocketMQ 5.x in proxy mode, several
remoting request codes are not supported by the broker directly:

- 106 GET_BROKER_CLUSTER_INFO
- 206 GET_ALL_TOPIC_LIST_FROM_NAMESERVER
- 208 GET_CONSUME_STATS

Add getBrokerClusterInfo, getAllTopicListFromNameServer, and
examineConsumeStats to ProxyAdmin/ProxyAdminImpl that send requests
to the configured proxy address.

Update ClusterServiceImpl, ClusterInfoService, TopicServiceImpl, and
ConsumerServiceImpl to fall back to the proxy when standard mqAdminExt
methods fail. This fixes:
- apache#402: request type 106/206 not supported
- apache#381: gRPC consumer latency showing -1 (consumeStats unavailable)
@github-actions

Copy link
Copy Markdown

This pull request has been automatically closed because there has been no activity for 7 days. If you would like to continue working on this, please reopen the PR with updated changes.

@github-actions github-actions Bot added the stale label Jul 18, 2026
@github-actions github-actions Bot closed this Jul 18, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

dashboard不显示grpc消息的消费者延迟,只显示-1 request type 106/206 not supported

1 participant