数据同步心跳机制

heartBeat Topic

federationmonitor

mongo

业务Topic

定时任务：(1分钟触发1次)脚本/monitor client定时写入heart beat消息数据库对应表metadata.debezium_heartbeatidf_service.public.debezium_heartbeat

springbootkafka template

heartBeat ack Topic

API repose:dataCenterIdcollectorNamelastHeartBeatTsspan style=\"font-size: inherit;\

API request:dataCenterIdcollectorName

receiver...

API查询collector同步状态

pg

idf_service.public.debezium_heartbeat

ackMessage:refHeartBeatIddataCenterIdreceiverNameackTimestamp

kafka

heartbeatMessage:uuIdtopicNamedataCenterIdcollectorNametimestamp

metadata.debezium_heartbeat

collector

消费heartBeat Topic

API查询DC总同步状态