flinkcdc消费postgre数据需要添加哪些maven依赖
时间: 2023-02-07 10:57:05 浏览: 280
flink cdc postgresql
要使用 Apache Flink 对 PostgreSQL 数据进行 CDC (change data capture, 数据变更捕获) 消费,你需要在你的项目中添加以下 Maven 依赖:
```
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-postgresql_2.11</artifactId>
<version>1.11.0</version>
</dependency>
```
这样就可以在你的 Flink 程序中使用 PostgreSQL connector 了。
需要注意的是,上述依赖的版本号 "1.11.0" 可能需要根据你实际使用的 Flink 版本进行调整。你可以在 Maven 中央仓库中查找最新版本的 Flink PostgreSQL connector。
阅读全文