摘要
基于高并发、稳定性、生态良好考虑,中移互联网有限公司部门项目引入成熟工具实现Kafka消息的异地节点同步,并采用一种基于滑动时间窗口的同步延迟检测算法实现Kafka消息同步进度的检测,从而很好地实现跨节点同步过程中,消息队列同步延迟的检测。
Based on high concurrency,stability,and good ecological considerations,the departmental project of China Mobile Internet Co.,Ltd.introduces mature tools to achieve off-site node synchronization of Kafka messages,and adopts a synchronization delay detection algorithm based on the sliding time window to achieve the detection of the synchronization progress of Kafka messages,so as to well achieve the detection of synchronization delays of the message queue in the process of cross-node synchronization.
作者
林德煜
LIN Deyu(China Mobile Internet Co.,Ltd.,Guangzhou 510653,China)
出处
《通信电源技术》
2023年第11期147-149,共3页
Telecom Power Technology
关键词
互联网
消息队列
容灾
数据同步
同步延迟检测
Internet
message queue
disaster recovery
data synchronization
synchronous delay detection