zergduan opened a new issue, #297: URL: https://github.com/apache/rocketmq-dashboard/issues/297
已确认最新master版本(Commit a450594)及Release 2.0.0版本，在多主集群中 Consumer Detail 只能显示一个主节点的消费进度，例如： Dashboard连接2主+2从 RocketMQ 5.3.2 集群，且TP-FTEST-Normal Topic 创建在 Broker-a 和 Broker-b 上（每个Broker上有4个队列），如下图：   消费组页面中查看GP-FTEST-Normal消费组的Consumer Detail信息，只能看到 Broker-a的消费进度，无法看到Broker-b上的消费进度，如下图：   从消费者日志可以确认，消费者从Broker-b中获取了消息消费，如下图：  在Dashboard的Consumer Group页面中，点击ConsumerDetail按钮时，在Dashboard服务器上使用tcpdump抓包（抓取与Broker 端口相关的TCP包，从TCP包中可以获取Broker发送给Dashboard的JSON，JSON中显示有Broker-a和Broker-b的消费进度信息，如下图：   可以确认Broker正常发送了Broker-a和Broker-b的信息给dashboard，但是dashboard仅仅显示了Broker-a的信息（消费进度） 组合TCP包中JSON，完整JSON信息如下： { "code": 0, "flag": 1, "language": "JAVA", "opaque": 1270, "remark": "not set any response code", "serializeTypeCurrentRPC": "JSON", "version": 477 }{ "mqPopTable": {}, "mqTable": { { "brokerName": "POC-Broker-a", "queueId": 0, "topic": "%RETRY%CG-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 72, "droped": false, "lastConsumeTimestamp": 1745303335796, "lastLockTimestamp": 1745303082346, "lastPullTimestamp": 1745305619173, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-b", "queueId": 0, "topic": "%RETRY%CG-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 48, "droped": false, "lastConsumeTimestamp": 1745303335678, "lastLockTimestamp": 1745303082347, "lastPullTimestamp": 1745305615620, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-a", "queueId": 0, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 401, "droped": false, "lastConsumeTimestamp": 1745303082339, "lastLockTimestamp": 1745303082339, "lastPullTimestamp": 1745305619173, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-a", "queueId": 1, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 407, "droped": false, "lastConsumeTimestamp": 1745303082326, "lastLockTimestamp": 1745303082326, "lastPullTimestamp": 1745305619173, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-a", "queueId": 2, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 406, "droped": false, "lastConsumeTimestamp": 1745303082333, "lastLockTimestamp": 1745303082333, "lastPullTimestamp": 1745305619173, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-a", "queueId": 3, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 400, "droped": false, "lastConsumeTimestamp": 1745303082342, "lastLockTimestamp": 1745303082342, "lastPullTimestamp": 1745305619173, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-b", "queueId": 0, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 401, "droped": false, "lastConsumeTimestamp": 1745303082337, "lastLockTimestamp": 1745303082337, "lastPullTimestamp": 1745305620620, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-b", "queueId": 1, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 400, "droped": false, "lastConsumeTimestamp": 1745303082340, "lastLockTimestamp": 1745303082340, "lastPullTimestamp": 1745305620620, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-b", "queueId": 2, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 402, "droped": false, "lastConsumeTimestamp": 1745303082331, "lastLockTimestamp": 1745303082331, "lastPullTimestamp": 1745305620620, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 }, { "brokerName": "POC-Broker-b", "queueId": 3, "topic": "TP-FTEST-Normal" }: { "cachedMsgCount": 0, "cachedMsgMaxOffset": 0, "cachedMsgMinOffset": 0, "cachedMsgSizeInMiB": 0, "commitOffset": 403, "droped": false, "lastConsumeTimestamp": 1745303082335, "lastLockTimestamp": 1745303082335, "lastPullTimestamp": 1745305620620, "locked": true, "transactionMsgCount": 0, "transactionMsgMaxOffset": 0, "transactionMsgMinOffset": 0, "tryUnlockTimes": 0 } }, "properties": { "consumeTimestamp": "20250422135440", "pullThresholdForTopic": "-1", "pullBatchSize": "32", "awaitTerminationMillisWhenShutdown": "0", "traceDispatcher": "org.apache.rocketmq.client.trace.AsyncTraceDispatcher@49ee7154", "consumeMessageBatchMaxSize": "1", "pullTimeDelayMillsWhenException": "1000", "enableStreamRequestType": "false", "pullThresholdForQueue": "1000", "language": "JAVA", "useHeartbeatV2": "false", "PROP_NAMESERVER_ADDR": "10.177.96.144:19876;10.177.96.143:19876;", "rpcHook": "org.apache.rocketmq.acl.common.AclClientRPCHook@16237179", "maxReconsumeTimes": "-1", "accessChannel": "LOCAL", "PROP_CONSUMEORDERLY": "false", "clientIP": "10.177.96.149", "mqClientApiTimeout": "3000", "decodeReadBody": "true", "suspendCurrentQueueTimeMillis": "1000", "PROP_CONSUMER_START_TIMESTAMP": "1745303080966", "PROP_CONSUME_TYPE": "CONSUME_PASSIVELY", "adjustThreadPoolNumsThreshold": "100000", "sendLatencyEnable": "false", "startDetectorEnable": "false", "consumeConcurrentlyMaxSpan": "2000", "popBatchNums": "32", "pullThresholdSizeForQueue": "100", "decodeDecompressBody": "true", "messageModel": "CLUSTERING", "pullBatchSizeInBytes": "262144", "namesrvAddr": "10.177.96.143:19876;10.177.96.144:19876", "allocateMessageQueueStrategy": "org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely@4ca05219", "messageListener": "Consumer_Normal$1@5268596c", "popThresholdForQueue": "96", "enableTrace": "true", "postSubscriptionWhenPull": "false", "consumerGroup": "CG-FTEST-Normal", "popInvisibleTime": "60000", "traceMsgBatchNum": "10", "log": "Logger[org.apache.rocketmq.client.consumer.DefaultMQPushConsumer]", "instanceName": "348833#339877795810223", "consumeFromWhere": "CONSUME_FROM_FIRST_OFFSET", "persistConsumerOffsetInterval": "5000", "subscription": "{}", "consumeThreadMax": "20", "unitMode": "false", "pollNameServerInterval": "30000", "pullInterval": "0", "detectInterval": "2000", "clientCallbackExecutorThreads": "4", "consumeTimeout": "15", "consumeThreadMin": "20", "useTLS": "true", "enableHeartbeatChannelEventListener": "true", "pullThresholdSizeForTopic": "-1", "offsetStore": "org.apache.rocketmq.client.consumer.store.RemoteBrokerOffsetStore@6353d0e8", "PROP_CLIENT_VERSION": "V5_3_2", "clientRebalance": "true", "PROP_THREADPOOL_CORE_SIZE": "20", "vipChannelEnabled": "false", "detectTimeout": "200", "heartbeatBrokerInterval": "30000", "socksProxyConfig": "{}", "defaultMQPushConsumerImpl": "org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl@77070e71", "namespaceInitialized": "true" }, "statusTable": { "%RETRY%CG-FTEST-Normal": { "consumeFailedMsgs": 0, "consumeFailedTPS": 0.0, "consumeOKTPS": 0.0, "consumeRT": 1.6, "pullRT": 0.0, "pullTPS": 0.0 }, "TP-FTEST-Normal": { "consumeFailedMsgs": 0, "consumeFailedTPS": 0.0, "consumeOKTPS": 0.0, "consumeRT": 0.0, "pullRT": 0.0, "pullTPS": 0.0 } }, "subscriptionSet": [ { "classFilterMode": false, "codeSet": [], "expressionType": "TAG", "subString": "*", "subVersion": 1745303082349, "tagsSet": [], "topic": "%RETRY%CG-FTEST-Normal" }, { "classFilterMode": false, "codeSet": [], "expressionType": "TAG", "subString": "*", "subVersion": 1745303082345, "tagsSet": [], "topic": "TP-FTEST-Normal" } ], "userConsumerInfo": {} } -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
