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总同步状态
