Java flink1.13.6 cdc 依赖

Flink CDC (Change Data Capture) 是 Apache Flink 中的一个功能模块，它允许用户从数据库中实时订阅并处理数据变更事件，而不仅仅是定期的数据批处理。在版本1.13.6中，Apache Flink 提供了对主流数据库（如 MySQL、PostgreSQL 等）的 CDC 支持。

如果你想要在 Java 项目中使用 Flink 1.13.6 和 CDC 功能，你需要做以下几件事：

1. 添加依赖：在你的 `pom.xml` 或者 `build.gradle` 文件中添加 Flink 的核心库以及 CDC 相关的插件依赖。例如：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>1.13.6</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-scala_2.11</artifactId>
    <version>1.13.6</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-cdc-sink_2.11</artifactId>
    <version>1.13.6</version>
</dependency>

这里的 `_2.11` 根据你的Scala版本可能会有所不同。

2. 配置连接和表描述：需要提供数据库连接信息，如用户名、密码、URL，以及你想捕获变更的表名及其对应的主键字段。

3. 创建 CDC 源：使用 Flink 的 CDC API 创建一个源，通常会使用特定的 JDBC 类型，比如 `TableSource` 或 `JdbcStreamExecutionEnvironment`。