diff --git a/lib/api/pulsar/pulsar_partitioned_topic_api.dart b/lib/api/pulsar/pulsar_partitioned_topic_api.dart
index 9dbc134..faa443c 100644
--- a/lib/api/pulsar/pulsar_partitioned_topic_api.dart
+++ b/lib/api/pulsar/pulsar_partitioned_topic_api.dart
@@ -219,9 +219,9 @@ class PulsarPartitionedTopicApi {
     int partitionNum = 0;
     double msgRateIn = 0;
     double msgRateOut = 0;
-    double msgInCounter = 0;
-    double msgOutCounter = 0;
-    double storageSize = 0;
+    int msgInCounter = 0;
+    int msgOutCounter = 0;
+    int storageSize = 0;
 
     if (statsMap.containsKey("metadata")) {
       Map metadata = statsMap["metadata"] as Map;
diff --git a/lib/api/pulsar/pulsar_topic_api.dart b/lib/api/pulsar/pulsar_topic_api.dart
index 82369e5..19ee033 100644
--- a/lib/api/pulsar/pulsar_topic_api.dart
+++ b/lib/api/pulsar/pulsar_topic_api.dart
@@ -182,9 +182,9 @@ class PulsarTopicApi {
     int partitionNum = 0;
     double msgRateIn = 0;
     double msgRateOut = 0;
-    double msgInCounter = 0;
-    double msgOutCounter = 0;
-    double storageSize = 0;
+    int msgInCounter = 0;
+    int msgOutCounter = 0;
+    int storageSize = 0;
 
     if (statsMap.containsKey("metadata")) {
       Map metadata = statsMap["metadata"] as Map;
diff --git a/lib/module/pulsar/pulsar_partitioned_topic_base.dart b/lib/module/pulsar/pulsar_partitioned_topic_base.dart
index 21a4910..f7ab3a4 100644
--- a/lib/module/pulsar/pulsar_partitioned_topic_base.dart
+++ b/lib/module/pulsar/pulsar_partitioned_topic_base.dart
@@ -3,9 +3,9 @@ class PulsarPartitionedTopicBaseResp {
   final int partitionNum;
   final double msgRateIn;
   final double msgRateOut;
-  final double msgInCounter;
-  final double msgOutCounter;
-  final double storageSize;
+  final int msgInCounter;
+  final int msgOutCounter;
+  final int storageSize;
 
   PulsarPartitionedTopicBaseResp(this.topicName, this.partitionNum, this.msgRateIn, this.msgRateOut, this.msgInCounter,
       this.msgOutCounter, this.storageSize);
diff --git a/lib/module/pulsar/pulsar_topic_base.dart b/lib/module/pulsar/pulsar_topic_base.dart
index 5adc418..f5ff5b6 100644
--- a/lib/module/pulsar/pulsar_topic_base.dart
+++ b/lib/module/pulsar/pulsar_topic_base.dart
@@ -3,9 +3,9 @@ class PulsarTopicBaseResp {
   final int partitionNum;
   final double msgRateIn;
   final double msgRateOut;
-  final double msgInCounter;
-  final double msgOutCounter;
-  final double storageSize;
+  final int msgInCounter;
+  final int msgOutCounter;
+  final int storageSize;
 
   PulsarTopicBaseResp(this.topicName, this.partitionNum, this.msgRateIn, this.msgRateOut, this.msgInCounter,
       this.msgOutCounter, this.storageSize);
diff --git a/lib/vm/pulsar/pulsar_partitioned_topic_basic_view_model.dart b/lib/vm/pulsar/pulsar_partitioned_topic_basic_view_model.dart
index 510cc90..f87475a 100644
--- a/lib/vm/pulsar/pulsar_partitioned_topic_basic_view_model.dart
+++ b/lib/vm/pulsar/pulsar_partitioned_topic_basic_view_model.dart
@@ -13,9 +13,9 @@ class PulsarPartitionedTopicBasicViewModel extends BaseLoadViewModel {
   String partitionNum = "";
   double msgRateIn = 0;
   double msgRateOut = 0;
-  double msgInCounter = 0;
-  double msgOutCounter = 0;
-  double storageSize = 0;
+  int msgInCounter = 0;
+  int msgOutCounter = 0;
+  int storageSize = 0;
 
   PulsarPartitionedTopicBasicViewModel(this.pulsarInstancePo, this.tenantResp, this.namespaceResp, this.topicResp);
 
diff --git a/lib/vm/pulsar/pulsar_topic_basic_view_model.dart b/lib/vm/pulsar/pulsar_topic_basic_view_model.dart
index 97a94f0..3e8de25 100644
--- a/lib/vm/pulsar/pulsar_topic_basic_view_model.dart
+++ b/lib/vm/pulsar/pulsar_topic_basic_view_model.dart
@@ -12,9 +12,9 @@ class PulsarTopicBasicViewModel extends BaseLoadViewModel {
   final TopicResp topicResp;
   double msgRateIn = 0;
   double msgRateOut = 0;
-  double msgInCounter = 0;
-  double msgOutCounter = 0;
-  double storageSize = 0;
+  int msgInCounter = 0;
+  int msgOutCounter = 0;
+  int storageSize = 0;
 
   PulsarTopicBasicViewModel(this.pulsarInstancePo, this.tenantResp, this.namespaceResp, this.topicResp);