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

Definition #

Data Source is used to access metadata and read the changed data from external systems.
A Data Source can read data from multiple tables simultaneously.

Parameters #

To describe a data source, the follows are required:

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

Example #

We could use yaml files to define a 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_\.*