From c977ce5690959501d9c031f11670574d4af6b492 Mon Sep 17 00:00:00 2001
From: zengqiao <zengqiao_cn@163.com>
Date: Tue, 25 May 2021 10:27:27 +0800
Subject: [PATCH] =?UTF-8?q?heartbeat=E8=A1=A8=E7=9A=84=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=97=B6=E9=97=B4=E4=BB=8EMySQL=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E7=94=9F=E6=88=90=E8=B0=83=E6=95=B4=E4=B8=BALogi-KM?=
 =?UTF-8?q?=E7=9A=84=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 kafka-manager-dao/src/main/resources/mapper/HeartbeatDao.xml   | 2 +-
 .../com/xiaojukeji/kafka/manager/task/component/Heartbeat.java | 3 +++
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/kafka-manager-dao/src/main/resources/mapper/HeartbeatDao.xml b/kafka-manager-dao/src/main/resources/mapper/HeartbeatDao.xml
index 900e13a9..bea686ff 100644
--- a/kafka-manager-dao/src/main/resources/mapper/HeartbeatDao.xml
+++ b/kafka-manager-dao/src/main/resources/mapper/HeartbeatDao.xml
@@ -11,7 +11,7 @@
     </resultMap>
 
     <insert id="replace" parameterType="com.xiaojukeji.kafka.manager.common.entity.pojo.HeartbeatDO">
-      REPLACE heartbeat (ip, hostname) VALUES (#{ip}, #{hostname})
+      REPLACE heartbeat (ip, hostname, modify_time) VALUES (#{ip}, #{hostname}, #{modifyTime})
     </insert>
 
     <select id="selectActiveHosts" parameterType="java.util.Date" resultMap="HeartbeatMap">
diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java
index 19db2588..d00c0ad0 100644
--- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java
+++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java
@@ -10,6 +10,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.util.Date;
+
 /**
  * @author limeng
  * @date 20/8/10
@@ -30,6 +32,7 @@ public class Heartbeat {
             HeartbeatDO heartbeatDO = new HeartbeatDO();
             heartbeatDO.setIp(NetUtils.localIp());
             heartbeatDO.setHostname(NetUtils.localHostname());
+            heartbeatDO.setModifyTime(new Date());
             heartbeatDao.replace(heartbeatDO);
         } catch (Exception e) {
             LOGGER.error("flush heartbeat failed.", e);