如何添加 Flink CDC 库依赖以使用 com.ververica.cdc.debezium.DebeziumDeserializationSchema 类
com.ververica.cdc.debezium.DebeziumDeserializationSchema 类是 Flink CDC 库中的一个类。要使用该类,您需要首先将 Flink CDC 库添加到您的项目依赖中。
您可以从 Maven 仓库 https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka 获取最新版本的 Flink CDC 库。
在您的项目中添加以下依赖项:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
请注意,'${scala.binary.version}' 和 '${flink.version}' 分别应替换为您正在使用的 Scala 和 Flink 版本。您可以在上面的链接中查找最新的版本号。
原文地址: https://www.cveoy.top/t/topic/lAB8 著作权归作者所有。请勿转载和采集!