Tag: Apache Flink

• Flink SQL 实时同步代码范例

  Public

  本项目演示如何使用 Flink SQL 1.20.3 实现从 MySQL 5.7 到 MySQL 8.0 的实时同步，支持部分表、部分字段过滤和动态取值过滤。 环境要求 Flink 1.20.3 MySQL 5.7 (源数据库) MySQL 8.0 (目标数据库) JDK 1.8+ 项目结构 fli

  Flink Updated 8月 19

• 基于Apache Flink CDC的多数据库实时数据同步项目

  Public

  基于 Flink 2.2.1 + Flink CDC 3.6.0-2.2 实现的多数据库实时数据同步项目。 功能特性 实时同步: 基于 CDC 实现毫秒级延迟的数据同步 多数据库支持: 支持 MySQL、PostgreSQL 等多种数据库作为 Source 和 Sink 动态字段过滤: 支持白名单(

  项目实战 Updated 8月 19