FlinkCDC里文档404，新的文档地址是什么？

新的文档地址是：https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/connectors/table/cdc/ 。

新的文档地址是：https://ci.apache.org/projects/flink/flinkdocsrelease1.13/zh/docs/connectors/table/cdc/

成都创新互联公司专注于企业营销型网站、网站重做改版、银海网站定制设计、自适应品牌网站建设、H5技术、商城网站建设、集团公司官网建设、成都外贸网站建设公司、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为银海等各大城市提供网站开发制作服务。

以下是Flink CDC的文档内容：

1、简介

Flink CDC是一个用于捕获数据库变更的工具，可以将数据库中的变更事件实时地流式传输到Flink中进行处理。

它支持多种数据库类型，包括MySQL、PostgreSQL、Oracle等。

2、特性

实时性：能够以毫秒级别的延迟捕获数据库变更事件。

容错性：通过ExactlyOnce语义保证数据的准确性和一致性。

可扩展性：可以处理大规模的数据流，并支持水平扩展。

3、使用步骤

添加依赖：在项目的构建文件中添加Flink CDC的依赖。

配置参数：设置数据库连接信息、表名等参数。

创建Flink流执行环境：创建一个Flink流执行环境，用于接收和处理CDC事件。

注册源表：将源表注册到Flink流执行环境中，指定要捕获的数据库表和变更事件的类型。

数据处理：编写处理逻辑，对CDC事件进行转换和计算。

输出结果：将处理后的结果输出到目标系统或存储介质。

4、示例代码

```java

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

import org.apache.flink.table.api.EnvironmentSettings;

import org.apache.flink.table.catalog.debezium.DebeziumOptions;

import org.apache.flink.table.catalog.debezium.DebeziumTableFactory;

public class FlinkCDCExample {

public static void main(String[] args) throws Exception {

// 创建流执行环境

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();

StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);

// 注册源表

tableEnv.registerTableSource("source_table", new DebeziumTableFactory().createTableSource(new MySqlConnectionOptions(), "mydb", "myschema", "mytable"));

// 数据处理逻辑...

// ...

// 输出结果到目标系统或存储介质...

// ...

}

```