8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-05 04:50:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

heartbeat表的数据更新时间从MySQL自动生成调整为Logi-KM的时间

Browse Source
This commit is contained in:
zengqiao
2021-05-25 10:27:27 +08:00
parent da7ad8b44a
commit c977ce5690
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka-manager-dao/src/main/resources/mapper/HeartbeatDao.xml
View File

@@ -11,7 +11,7 @@
</resultMap> </resultMap>
<insert id="replace" parameterType="com.xiaojukeji.kafka.manager.common.entity.pojo.HeartbeatDO"> <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> </insert>
<select id="selectActiveHosts" parameterType="java.util.Date" resultMap="HeartbeatMap"> <select id="selectActiveHosts" parameterType="java.util.Date" resultMap="HeartbeatMap">

3
kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/Heartbeat.java
View File

@@ -10,6 +10,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.Date;
/** /**
* @author limeng * @author limeng
* @date 20/8/10 * @date 20/8/10
@@ -30,6 +32,7 @@ public class Heartbeat {
HeartbeatDO heartbeatDO = new HeartbeatDO(); HeartbeatDO heartbeatDO = new HeartbeatDO();
heartbeatDO.setIp(NetUtils.localIp()); heartbeatDO.setIp(NetUtils.localIp());
heartbeatDO.setHostname(NetUtils.localHostname()); heartbeatDO.setHostname(NetUtils.localHostname());
heartbeatDO.setModifyTime(new Date());
heartbeatDao.replace(heartbeatDO); heartbeatDao.replace(heartbeatDO);
} catch (Exception e) { } catch (Exception e) {
LOGGER.error("flush heartbeat failed.", e); LOGGER.error("flush heartbeat failed.", e);