推荐使用 TiCDC 同步到 Kafka 然后再用 Flink 消费。https://docs.pingcap.com/zh/tidb/stable/manage-ticdc#sink-uri-配置-kafka