Getting Started

• Streaming ETL for MySQL and Postgres with Flink CDC
  • Preparation
  • Starting Flink cluster and Flink SQL CLI
  • Creating tables using Flink DDL in Flink SQL CLI
  • Enriching orders and load to ElasticSearch
  • Clean up
• Demo: MongoDB CDC to Elasticsearch
• Demo: Oracle CDC to Elasticsearch
• Using Flink CDC to synchronize data from MySQL sharding tables and build real-time data lake
  • Preparation
  • Creating tables using Flink DDL in Flink SQL CLI
  • Streaming to Iceberg
  • Clean up