Flink CDC系列之：学习理解核心概念——Data Source
Flink CDC系列之：学习理解核心概念——Data Source
- source
- 参数
- 示例
source
数据源用于访问元数据并从外部系统读取更改的数据。
数据源可以同时从多个表读取数据。
参数
要描述数据源，需要以下内容：
| 参数 | 含义 | 可选/必需 |
|---|---|---|
| type | 源的类型，例如 mysql。 | 必需 |
| name | 源的名称，用户定义（提供默认值）。 | 可选 |
| 数据源配置 | 构建数据源的配置，例如连接配置和源表属性。 | 可选 |
示例
我们可以使用 yaml 文件来定义 mysql 源：
source:
type: mysql
name: mysql-source #optional，description information
host: localhost
port: 3306
username: admin
password: pass
tables: adb.*, bdb.user_table_[0-9]+, [app|web]_order_\.*