https://github.com/ververica/flink-cdc-connectors/blob/7ea197242f82d1f63f0e10c6c79ed283f2f7adb7/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/com/ververica/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java#L104
你在tidb这里问其他中间件没有问题。 好歹提供一下flink-cdc-connectors版本信息。 至少看上去，现在已经不是这么写的了。