Flink CDC这个MySqlSource弃用了,还有别的方式吗?
用这个包
import org.apache.flink.cdc.connectors.mysql.source.MySqlSource;
dependency>
groupId>org.apache.flink/groupId>
artifactId>flink-connector-mysql-cdc/artifactId>
version>3.1.0/version>
/dependency>
参考官网https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/connectors/flink-sources/mysql-cdc/
赞0
踩0