快速上手

• 基于 Flink CDC 3.0 构建 MySQL 到 Doris 的 Streaming ELT
  • 准备阶段
  • 通过 FlinkCDC cli 提交任务
  • 环境清理
• 基于 Flink CDC 3.0 构建 MySQL 到 StarRocks 的 Streaming ELT
  • 准备阶段
  • 通过 FlinkCDC cli 提交任务
  • 环境清理
• 基于 Flink CDC 构建 MySQL 和 Postgres 的 Streaming ETL
  • 准备阶段
  • 启动 Flink 集群和 Flink SQL CLI
  • 在 Flink SQL CLI 中使用 Flink DDL 创建表
  • 关联订单数据并且将其写入 Elasticsearch 中
  • 环境清理
• 演示: MongoDB CDC 导入 Elasticsearch
• 演示: OceanBase CDC 导入 Elasticsearch
  • 视频教程
• 演示: Oracle CDC 导入 Elasticsearch
• 演示: PolarDB-X CDC 导入 Elasticsearch
  • 准备教程所需要的组件
  • 准备数据：
  • 下载 Flink 和所需要的依赖包
  • 在 Flink SQL CLI 中使用 Flink DDL 创建表
  • 在 Kibana 中查看数据
  • 修改监听表数据，查看增量数据变动
  • 环境清理
• 演示: SqlServer CDC 导入 Elasticsearch
• 演示: TiDB CDC 导入 Elasticsearch
• 基于 Flink CDC 同步 MySQL 分库分表构建实时数据湖
  • 准备阶段
  • 在 Flink SQL CLI 中使用 Flink DDL 创建表
  • 流式写入 Iceberg
  • 环境清理
• DataStream api 打包指南
  • 框架版本
  • pom 示例
  • 代码示例