Flink CDC 监听 MySQL 数据变化并发送到 Kafka 技术指南
Flink CDC 监听 MySQL 数据变化并发送到 Kafka 技术指南
为了监听MySQL中名为student的表的变化，并将这些变化发送到Kafka，我们将使用Flink CDC (Change Data Capture)。
以下是详细的步骤和SQL语句，用于配置Flink SQL环境以实现这个目标。
1. 确认环境准备
确保你已经按照之前的指导完成了环境的准备工作，包括：
- 安装并配置了MySQL（开启了binlog）。
- 安装并启动了Kafka集群，并创建了一个目标Topic。
- 安装并配置了Flink及其相关依赖。
2. 创建MySQL Source Table
在Flink SQL环境中，你需要定义一个源表来表示MySQL中的student表。这里假设你已经在MySQL中创建了如下的student表：
CREATE TABLE