快速上手

• 基于 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
  • 环境清理