快速上手

• 基于 Flink CDC 构建 MySQL 和 Postgres 的 Streaming ETL
  • 准备阶段
  • 启动 Flink 集群和 Flink SQL CLI
  • 在 Flink SQL CLI 中使用 Flink DDL 创建表
  • 关联订单数据并且将其写入 Elasticsearch 中
  • 环境清理
• 演示: MongoDB CDC 导入 Elasticsearch
• 演示: Oracle CDC 导入 Elasticsearch
• 基于 Flink CDC 同步 MySQL 分库分表构建实时数据湖
  • 准备阶段
  • 在 Flink SQL CLI 中使用 Flink DDL 创建表
  • 流式写入 Iceberg
  • 环境清理