(rocketmq-dashboard) branch rocketmq-studio updated: fix(rocketmq): read getTransferredTps key for outbound tps (#1156)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimins pushed a commit to branch rocketmq-studio
in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git


The following commit(s) were added to refs/heads/rocketmq-studio by this push:
     new fad96313 fix(rocketmq): read getTransferredTps key for outbound tps 
(#1156)
fad96313 is described below

commit fad96313a38d441d2d9bf47e657131648a0904cf
Author: 0 <1939455...@qq.com>
AuthorDate: Fri Aug 7 16:14:45 2026 +0800

    fix(rocketmq): read getTransferredTps key for outbound tps (#1156)
---
 .../rocketmq/studio/provider/apache/RocketMQClusterProvider.java      | 2 +-
 .../rocketmq/studio/provider/apache/RocketMQDashboardProvider.java    | 4 ++--
 .../rocketmq/studio/provider/apache/RocketMQClusterProviderTest.java  | 2 +-
 .../studio/provider/apache/RocketMQDashboardProviderTest.java         | 2 +-
 4 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProvider.java
 
b/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProvider.java
index bdf0990b..2878cfc8 100644
--- 
a/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProvider.java
+++ 
b/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProvider.java
@@ -199,7 +199,7 @@ public class RocketMQClusterProvider implements 
ClusterProvider {
                 builder.tpsIn(parseFirstTpsValue(putTps));
             }
 
-            String getTransferredTps = table.get("getTransferedTps");
+            String getTransferredTps = table.get("getTransferredTps");
             if (getTransferredTps != null && !getTransferredTps.isEmpty()) {
                 builder.tpsOut(parseFirstTpsValue(getTransferredTps));
             }
diff --git 
a/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
 
b/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
index 6ffd6270..7283a798 100644
--- 
a/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
+++ 
b/server/src/main/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProvider.java
@@ -147,7 +147,7 @@ public class RocketMQDashboardProvider implements 
DashboardProvider {
                     if (runtimeInfo != null && runtimeInfo.getTable() != null) 
{
                         Map<String, String> table = runtimeInfo.getTable();
                         tpsIn += parseTps(table.get("putTps"));
-                        tpsOut += parseTps(table.get("getTransferedTps"));
+                        tpsOut += parseTps(table.get("getTransferredTps"));
 
                         String msgPutToday = 
table.get("msgPutTotalTodayMorning");
                         if (msgPutToday != null) {
@@ -182,7 +182,7 @@ public class RocketMQDashboardProvider implements 
DashboardProvider {
                                 KVTable rt = 
admin.fetchBrokerRuntimeStats(masterAddr);
                                 if (rt != null && rt.getTable() != null) {
                                     clusterTpsIn += (int) 
parseTps(rt.getTable().get("putTps"));
-                                    clusterTpsOut += (int) 
parseTps(rt.getTable().get("getTransferedTps"));
+                                    clusterTpsOut += (int) 
parseTps(rt.getTable().get("getTransferredTps"));
                                     String v = 
rt.getTable().get("brokerVersionDesc");
                                     if (v != null && 
"unknown".equals(version)) {
                                         String brokerVersion = v.trim();
diff --git 
a/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProviderTest.java
 
b/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProviderTest.java
index 9ad22c67..8c5eca22 100644
--- 
a/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProviderTest.java
+++ 
b/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQClusterProviderTest.java
@@ -113,7 +113,7 @@ class RocketMQClusterProviderTest {
         KVTable table = new KVTable();
         HashMap<String, String> stats = new HashMap<>();
         stats.put("putTps", "  12.7   10.0  9.0");
-        stats.put("getTransferedTps", "\t34.2  30.0  29.0");
+        stats.put("getTransferredTps", "\t34.2  30.0  29.0");
         table.setTable(stats);
         return table;
     }
diff --git 
a/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
 
b/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
index f150536a..5ca3b7ca 100644
--- 
a/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
+++ 
b/server/src/test/java/org/apache/rocketmq/studio/provider/apache/RocketMQDashboardProviderTest.java
@@ -150,7 +150,7 @@ class RocketMQDashboardProviderTest {
         HashMap<String, String> table = new HashMap<>();
         table.put("brokerVersionDesc", "  V5_3_3  ");
         table.put("putTps", "1.0 2.0 3.0");
-        table.put("getTransferedTps", "4.0 5.0 6.0");
+        table.put("getTransferredTps", "4.0 5.0 6.0");
         table.put("msgPutTotalTodayMorning", "42");
 
         KVTable kvTable = new KVTable();