gitdongjian

目前cdc支持gtid点位消费吗？

云邪大佬，感谢回复，问题是这样的 我们dba某次进行了数据库的切换操作，然后我的mysql cdc就挂掉了，我把报错信息贴一下 dba反馈是我没有使用gtid？不知道flink cdc这边是否支持？ 如果不支持安装单独的Debezium采集服务需要做什么样的特殊配置才能支持gtid？在官网没找到配置支持gtid的地方？ org.apache.kafka.connect.errors.ConnectException: The connector is trying to read binlog starting at GTIDs 3fa7d5bb-65f3-11eb-9413-b0262879b560:1-730774004 and binlog file 'mysql-bin.000650', pos=521310219, skipping 2 events plus 1 rows, but...

hello，云邪，我们的db是支持VIP的形式，也就是不用手工改hostname就可以访问新的数据库。 但是问题是比如 hostname = A， 然后 A 挂了，B成为了新主，checkpoint里边最后记录的binlog-file和pos是A的快照，在新的B上找不到对应的文件。所以导致我的flink job任务始终起不来。 dba反馈是2台机器的binlog不一致导致，所以导致挂了，dba建议采用gtid的同步方式。 不知道我们cdc这边是否支持呢？目前到底是什么原因我还没查出来，困扰了很久，云邪大佬这边能给点建议吗？ 非常感谢！ At 2021-06-09 19:48:53, "Jark Wu" ***@***.***> wrote: @gitdongjian , 目前还不支持自动切换，需要手动切换。比如原先的 hostname = A， 然后 A 挂了，B成为了新主，这时候 flink job...