flinkcdc依赖引入
时间: 2023-09-02 17:07:06 浏览: 92
flink CDC监控PG数据库的demo案例
要在 Maven 项目中引入 Flink CDC 的依赖,可以在 pom.xml 文件中添加以下代码:
```xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-cdc-connectors</artifactId>
<version>${flink.version}</version>
</dependency>
```
其中 `${flink.version}` 是 Flink 的版本号,可以根据实际情况进行替换。
如果使用的是 Scala 项目,可以使用以下代码:
```xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-cdc-connectors_2.11</artifactId>
<version>${flink.version}</version>
</dependency>
```
其中 `_2.11` 表示使用的是 Scala 2.11 版本,如果使用的是其他版本的 Scala,需要根据实际情况进行替换。
阅读全文