Flink CDC系列之：学习理解核心概念——Data Sink
Flink CDC系列之：学习理解核心概念——Data Sink
- sink
- 参数
- 示例
sink
数据接收器用于应用架构更改并将更改数据写入外部系统。
数据接收器可以同时写入多个表。
参数
为了描述数据接收器，需要以下内容：
| 参数 | 含义 | 可选/必需 |
|---|---|---|
| type | sink的类型，例如 doris 或 starrocks。 | 必需 |
| name | 接收器的名称，由用户定义（提供默认值）。 | 可选 |
| 数据源配置 | 构建数据接收器的配置，例如连接配置和接收器表属性。 | 可选 |
示例
我们可以使用这个 yaml 文件来定义 doris 接收器：
sink:
type: doris
name: doris-sink # Optional parameter for description purpose
fenodes: 127.0.0.1:8030
username: root
password: ""
table.create.properties.replication_num: 1 # Optional parameter for advanced functionalities