场景:
单线程canal应用
docker tcp重传上去了,夯了5分钟,不超时。
备机起来了,正常消费灌数据了。
5分钟后,那台docker执行成功了,拿着脏数据覆盖过去了!!!
所以,要有版本号,发现是旧的直接舍弃调。。
================
插入的时候,,binlake已经收到去补偿了,而这个时候插入缓存的代码还没执行完。。。 -> 先者慢了
->后者快了
场景:
单线程canal应用
docker tcp重传上去了,夯了5分钟,不超时。
备机起来了,正常消费灌数据了。
5分钟后,那台docker执行成功了,拿着脏数据覆盖过去了!!!
所以,要有版本号,发现是旧的直接舍弃调。。
================
插入的时候,,binlake已经收到去补偿了,而这个时候插入缓存的代码还没执行完。。。 -> 先者慢了
->后者快了