From 5f21e5a728580d91a028b39888de91ad33ffec86 Mon Sep 17 00:00:00 2001
From: _haoqi <1148648445@qq.com>
Date: Fri, 14 Oct 2022 11:53:48 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9zk-Latency=20avg=E4=B8=BA?=
 =?UTF-8?q?=E5=B0=8F=E6=95=B0=E6=97=B6=E7=9A=84=E6=95=B0=E5=80=BC=E8=BD=AC?=
 =?UTF-8?q?=E6=8D=A2=E5=BC=82=E5=B8=B8=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../bean/entity/zookeeper/fourletterword/MonitorCmdData.java    | 2 +-
 .../bean/entity/zookeeper/fourletterword/ServerCmdData.java     | 2 +-
 .../zookeeper/fourletterword/parser/MonitorCmdDataParser.java   | 2 +-
 .../zookeeper/fourletterword/parser/ServerCmdDataParser.java    | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/MonitorCmdData.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/MonitorCmdData.java
index 7ea1339b..2fb3c9da 100644
--- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/MonitorCmdData.java
+++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/MonitorCmdData.java
@@ -22,7 +22,7 @@ import lombok.Data;
 @Data
 public class MonitorCmdData extends BaseFourLetterWordCmdData {
     private String zkVersion;
-    private Long zkAvgLatency;
+    private Float zkAvgLatency;
     private Long zkMaxLatency;
     private Long zkMinLatency;
     private Long zkPacketsReceived;
diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/ServerCmdData.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/ServerCmdData.java
index 38bd2cf9..883231d6 100644
--- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/ServerCmdData.java
+++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/ServerCmdData.java
@@ -17,7 +17,7 @@ import lombok.Data;
 @Data
 public class ServerCmdData extends BaseFourLetterWordCmdData {
     private String zkVersion;
-    private Long zkAvgLatency;
+    private Float zkAvgLatency;
     private Long zkMaxLatency;
     private Long zkMinLatency;
     private Long zkPacketsReceived;
diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/MonitorCmdDataParser.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/MonitorCmdDataParser.java
index a33f4da3..55921c12 100644
--- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/MonitorCmdDataParser.java
+++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/MonitorCmdDataParser.java
@@ -57,7 +57,7 @@ public class MonitorCmdDataParser implements FourLetterWordDataParser<MonitorCmd
                         monitorCmdData.setZkVersion(elem.getValue().split("-")[0]);
                         break;
                     case "zk_avg_latency":
-                        monitorCmdData.setZkAvgLatency(Long.valueOf(elem.getValue()));
+                        monitorCmdData.setZkAvgLatency(Float.valueOf(elem.getValue()));
                         break;
                     case "zk_max_latency":
                         monitorCmdData.setZkMaxLatency(Long.valueOf(elem.getValue()));
diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ServerCmdDataParser.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ServerCmdDataParser.java
index f91f19a8..c4cbcd0f 100644
--- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ServerCmdDataParser.java
+++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/zookeeper/fourletterword/parser/ServerCmdDataParser.java
@@ -54,7 +54,7 @@ public class ServerCmdDataParser implements FourLetterWordDataParser<ServerCmdDa
                     case "Latency min/avg/max":
                         String[] data = elem.getValue().split("/");
                         serverCmdData.setZkMinLatency(Long.valueOf(data[0]));
-                        serverCmdData.setZkAvgLatency(Long.valueOf(data[1]));
+                        serverCmdData.setZkAvgLatency(Float.valueOf(data[1]));
                         serverCmdData.setZkMaxLatency(Long.valueOf(data[2]));
                         break;
                     case "Received":