Flink CDC 强势来袭，流计算带来惊喜

2023-08-06 23:57:23

Flink CDC 和 Flink 流式湖仓 Paimon：开启实时数据处理新时代

Flink CDC：实时数据捕获的强大引擎

Flink CDC（Change Data Capture）是阿里云自主研发的流计算引擎，它能够帮助企业实时捕捉数据库的变化数据，并将其写入到下游存储系统中。Flink CDC 在 FFA 2023 中进行了重磅升级，带来了许多新的特性和优化，让实时计算变得更加强大。

MySQL、PostgreSQL、Oracle 和 SQL Server 的全面支持

Flink CDC 支持主流数据库，包括 MySQL、PostgreSQL、Oracle 和 SQL Server。这意味着企业可以轻松地将这些数据库中的数据实时写入到下游存储系统中。

全新的数据传输协议：大幅提升效率和稳定性

Flink CDC 采用了全新的数据传输协议，大幅提升了数据传输效率和稳定性。在 FFA 2023 的现场演示中，Flink CDC 能够在 1 秒内将 100 万条数据从 MySQL 数据库传输到下游存储系统中，这使得实时计算的时延大幅降低。

丰富的内置函数和操作符：轻松处理和转换数据

Flink CDC 提供了丰富的内置函数和操作符，帮助企业轻松地处理和转换数据。例如，Flink CDC 可以帮助企业将数据清洗、过滤、聚合和关联，并将其写入到下游存储系统中。

Flink 流式湖仓 Paimon：流计算和湖仓存储的完美结合

Flink 流式湖仓 Paimon 是阿里云推出的全新产品，它将流计算和湖仓存储完美地结合在一起，为企业提供了一种全新的实时数据处理方案。

实时数据处理：获取数据的第一时间

Flink 流式湖仓 Paimon 能够实时地处理数据，并将其写入到湖仓存储系统中。这使得企业能够在第一时间获取数据，并进行分析和处理。

统一存储：流数据和批数据的一站式存储

Flink 流式湖仓 Paimon 将流数据和批数据统一存储在湖仓存储系统中，这使得企业能够轻松地对数据进行查询和分析。

弹性扩缩容：成本节约和资源优化

Flink 流式湖仓 Paimon 能够根据数据量的变化自动弹性扩缩容，这使得企业能够节省成本。

易于使用：友好的用户界面和丰富的 API

Flink 流式湖仓 Paimon 提供了友好的用户界面和丰富的 API，这使得企业能够轻松地使用该产品。

Flink CDC 和 Flink 流式湖仓 Paimon 的协同效应

Flink CDC 和 Flink 流式湖仓 Paimon 的结合，为企业带来了无限的可能。企业可以利用 Flink CDC 实时捕捉数据库的变化数据，并将其写入到 Flink 流式湖仓 Paimon 中。然后，企业可以使用 Flink 流式湖仓 Paimon 对数据进行查询和分析，并将其用于各种业务场景中。

业务场景应用：无限的可能性

Flink CDC 和 Flink 流式湖仓 Paimon 的结合，可以为企业实现以下业务场景：