Data Sink
This documentation is for an unreleased version of Apache Flink CDC. We recommend you use the latest stable version.

Definition #

Data Sink is used to apply schema changes and write change data to external systems.
A Data Sink can write to multiple tables simultaneously.

Parameters #

To describe a data sink, the follows are required:

parameter meaning optional/required
type The type of the sink, such as doris or starrocks. required
name The name of the sink, which is user-defined (a default value provided). optional
configurations of Data Sink Configurations to build the Data Sink e.g. connection configurations and sink table properties. optional

Example #

We could use this yaml file to define a doris sink:

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