ticdc 在 6.x 才有很多修复， 5.x bug也比较多
要解决问题，可以考虑采用 ticdc 把数据分发到 kafka，在通过 flink 对接 kafka 即可，稍微麻烦点
看你对是否有帮助了