From 9d50ad191a38a3e831073af9df776a97b0f2f3a9 Mon Sep 17 00:00:00 2001
From: morning <893136369@qq.com>
Date: Sat, 28 Mar 2026 09:31:39 +0000
Subject: [PATCH] fix an collectBrokerRuntimeStats error

---
 .../org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java b/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java
index 921b5af..9a554cd 100644
--- a/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java
+++ b/src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java
@@ -115,7 +115,7 @@ public BrokerRuntimeStats(KVTable kvTable) {
         this.pullThreadPoolQueueHeadWaitTimeMills = Long.parseLong(kvTable.getTable().get("pullThreadPoolQueueHeadWaitTimeMills"));
         this.runtime = kvTable.getTable().get("runtime");
         this.dispatchMaxBuffer = Long.parseLong(kvTable.getTable().get("dispatchMaxBuffer"));
-        this.brokerVersion = Integer.parseInt(kvTable.getTable().get("brokerVersion"));
+        this.brokerVersion = kvTable.getTable().get("brokerVersion") == null ? -1 : Integer.parseInt(kvTable.getTable().get("brokerVersion"));
         this.consumeQueueDiskRatio = Double.parseDouble(kvTable.getTable().get("consumeQueueDiskRatio"));
         this.pageCacheLockTimeMills = Long.parseLong(kvTable.getTable().get("pageCacheLockTimeMills"));
         this.commitLogDiskRatio = Double.parseDouble(kvTable.getTable().get("commitLogDiskRatio"));