系列文章目录

背景篇

环境篇

1.  准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。
2. 准备教程所需要的组件
3. 版本对应关系
4. 安装
5. 环境检查

工具篇

1. flink
2. kibana

概念篇

1. Docker 介 绍
2. Docker Compose 介 绍
3. Kibana介 绍

实践篇

演示: Mysql CDC 导入 Elasticsearch

1. 启动服务
2. 准备数据
3. 在 Flink SQL CLI 中使用 Flink DDL 创建表
4. 关联订单数据并且将其写入 Elasticsearch 中
5. 环境清理

演示: postgres CDC 导入 Elasticsearch

1. 启动 Flink 集群和 Flink SQL CLI
2. 在 Flink SQL CLI 中使用 Flink DDL 创建表
3. 将其写入 Elasticsearch 中
4. 环境清理

演示: MongoDB CDC 导入 Elasticsearch

1. 启动 Flink 集群和 Flink SQL CLI
2. 在 Flink SQL CLI 中使用 Flink DDL 创建表
3. 将其写入 Elasticsearch 中
4. 环境清理

演示: Mysql CDC 导入 Kafka

1. 在 MySQL 数据库中准备数据
2. 启动 Flink 集群和 Flink SQL CLI
3. 在 Flink SQL CLI 中使用 Flink DDL 创建表
4. kafka控制台相关命令
5. 环境清理

遇到问题

1. 版本兼容问题
2. docker-compose安装问题
3. 容器启动失败问题
4. Flink SQL执行失败问题