flink tidb-cdc 出错期间增量数据怎么保证一致性的

请问下flink tidb-cdc怎么保证flink集群出错至下次恢复后在此期间增量的部分可以得到正确的同步呢,这个是怎么做的,tidb对应的binlog是否会保存在flink中

flink cdc 对于 tidb 的connector 的处理,并不是tidb 官方的出品,你的问题需要去 flink 和 flink cdc 的github 上去提 issue了

此话题已在最后回复的 60 天后被自动关闭。不再允许新回复。