kafka connector 从源系统数据库同步数据到目的数据库，如何知道已经同步完成了

冷风吃不掉的微笑 发表于: 2019-12-18   最后更新时间: 2019-12-18 15:43:58   2,137 游览

kafka connector 从源系统数据库同步数据到目的数据库，如何知道已经同步完成了

kafka connector 从源系统mysql数据库同步数据到目的系统数据库，如何知道已经同步完成了，并且告诉目的系统数据已经同步完成

kafka
发表于 2019-12-18
冷风吃不掉的微笑
添加评论

这种流式异步处理本身就很难界定“完成”，而且又是多task，本身connect是没法做的吧。
如果非要做可以写个旁支程序，设置一个静默时间slienceTime（可以使redis可以是取的到的单例变量），比如task有数据时就把slienceTime赋为0，另一个定时任务每一秒把这个slienceTime+1，等到slienceTime==60时就知道connect已经60s没处理数据了

回复
回答于 5年前
SONG
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。