目前有个合并不同mysql源表为宽表,并持续同步到另一个目标源场景,当前采用了kafka connect实现,主表的sourceConnect使用插入或更新的方式同步,其余从表使用更新的方式完成,目前问题是,当我从表使用增量更新,如何解决从表数据比主表数据早到,导致早到的从表数据无法更新到目标表中
这个顺序问题,对kafka应该是无解的。
即便是自己在业务层写逻辑,我也很难想到该怎么处理。
目前能想到的办法只有,每次全量获取从表数据,但是这样操作会带来很大的数据库压力,效率也比增量低,但是不这样做,感觉不知道如何下手
是的,你这2个要建立耦合关系才行,比如A完成到某个点,去触发B,B到了某个点就停止,等待下次唤醒。
你的答案