Flink SQL connector = 'mysql' 和connector = 'mysql-cdc'有啥区别?
时间: 2024-01-15 08:03:55 浏览: 307
flink-sql-connector-mysql-cdc-2.3.0.jar
`connector = 'mysql'` 和 `connector = 'mysql-cdc'` 在 Flink SQL 中也是两个不同的连接器,分别用于不同的工作场景。
- `connector = 'mysql'`:这是 Flink SQL 官方提供的连接器之一,用于连接 MySQL 数据库,支持读取和写入 MySQL 数据库中的数据。它适用于一般的 MySQL 数据库读写操作。
- `connector = 'mysql-cdc'`:这也是一个基于 MySQL 官方提供的 Python 库(mysql-connector-python)开发的插件,用于捕获 MySQL 数据库的 binlog 日志,从而实现 MySQL 数据库的实时数据同步、数据分析等功能。它侧重于 CDC 场景,可以在 Flink SQL 中实现实时数据同步、数据分析等功能。
因此,如果你只需要进行一般的 MySQL 数据库读写操作,那么可以使用 `connector = 'mysql'`;如果需要进行实时数据同步、数据分析等功能,那么可以考虑使用 `connector = 'mysql-cdc'`。需要注意的是,`connector = 'mysql-cdc'` 需要安装 binlog 日志插件,因此配置相对比较复杂。
阅读全文