Dataphin:Create a real-time integration task

Parameter

Description

Data Source Configuration

Data Source Type

Select MySQL.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a MySQL data source.

Time Zone

The time zone configured for the selected data source.

Sync Rule Configuration

Sync Solution

Select Real-time Incremental or Real-time Incremental + Full. The default value is Real-time Incremental.

• Real-time Incremental: Collects incremental changes from the source database and writes them to the downstream destination database in the order they occur.

• Real-time Incremental + Full: Imports the full data from the source database at one time, and then collects and writes incremental changes to the downstream destination database in the order they occur.

Selection Method

You can select Entire Database, Select Tables, or Exclude Tables.

• Entire Database: Synchronizes all tables in all databases under the selected data source.

• Select Tables/Exclude Tables: Selects some tables in the current database for real-time synchronization. After you select tables, click Preview to view all matched tables in the Select/Exclude Table Preview dialog box. In the dialog box, you can search for tables by keyword and delete tables individually or in batches. You cannot delete tables if you use Regex Match.

  • Batch Select/Batch Exclude: If you select Batch Select, multiple selected tables in the current database are synchronized in real time. If you select Batch Exclude, multiple selected tables in the current database are not synchronized in real time.

    You can select all tables in all databases under the selected data source. Tables are displayed in the format of DBname.Tablename.

  • Regex Match: Enter a regular expression for table names in the Regular Expression input box. Java regular expressions are supported, such as schemaA.*|schemaB.*.

    You can match all tables in all databases under the selected data source in batches. You can use the database name (DBname) and table name (Tablename) for regex matching.

Parameter

Description

Data Source Configuration

Data Source Type

Select Microsoft SQL Server.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a Microsoft SQL Server data source.

Time Zone

The time zone configured for the selected data source.

Sync Rule Configuration

Sync Solution

Only Real-time Incremental is supported. Collects incremental changes from the source database and writes them to the downstream destination database in real time in the order they occur.

Selection Method

You can select Entire Database, Select Tables, or Exclude Tables.

• Entire Database: Synchronizes data for the entire current database.

• Select Tables/Exclude Tables: Selects some tables in the current database for real-time synchronization. After you select tables, click Preview to view all matched tables in the Select/Exclude Table Preview dialog box. In the dialog box, you can search for tables by keyword and delete tables individually or in batches.

  Batch Select/Batch Exclude: If you select Batch Select, multiple selected tables in the current database are synchronized in real time. If you select Batch Exclude, multiple selected tables in the current database are not synchronized in real time.

Parameter

Description

Data Source Configuration

Data Source Type

Select PostgreSQL.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a PostgreSQL data source.

Time Zone

The time zone configured for the selected data source.

Sync Rule Configuration

Sync Solution

Only Real-time Incremental is supported. Collects incremental changes from the source database and writes them to the downstream destination database in real time in the order they occur.

Selection Method

You can select Entire Database or Select Tables.

• Entire Database: Synchronizes data for the entire current database.

• Select Tables: Selects some tables in the current database for real-time synchronization. After you select tables, click Preview to view all matched tables in the Select Table Preview dialog box. In the dialog box, you can search for tables by keyword and delete tables individually or in batches.

  Batch Select: The selected tables in the current database are synchronized in real time.

Parameter

Description

Data Source Configuration

Data Source Type

Select Oracle.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create an Oracle data source.

Time Zone

The time zone configured for the selected data source.

Sync Rule Configuration

Sync Solution

Only Real-time Incremental is supported. Collects incremental changes from the source database and writes them to the downstream destination database in real time in the order they occur.

Selection Method

You can select Entire Database, Select Tables, or Exclude Tables.

• Entire Database: Synchronizes all tables in all databases under the selected data source.

• Select Tables/Exclude Tables: Selects some tables in the current database for real-time synchronization. After you select tables, click Preview to view all matched tables in the Select/Exclude Table Preview dialog box. In the dialog box, you can search for tables by keyword and delete tables individually or in batches. You cannot delete tables if you use Regex Match.

  • Batch Select/Batch Exclude: If you select Batch Select, multiple selected tables in the current database are synchronized in real time. If you select Batch Exclude, multiple selected tables in the current database are not synchronized in real time.

  • Regex Match: Enter a regular expression for table names in the Regular Expression input box. Java regular expressions are supported, such as schemaA.*|schemaB.*.

Parameter

Description

Data Source Configuration

Data Source Type

Select IBM DB2.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create an IBM DB2 data source.

Sync Rule Configuration

Sync Solution

Only Real-time Incremental is supported. Collects incremental changes from the source database and writes them to the downstream destination database in real time in the order they occur.

Selection Method

You can select Entire Database, Select Tables, or Exclude Tables.

• Entire Database: Synchronizes all tables in all databases under the selected data source.

• Select Tables/Exclude Tables: Selects some tables in the current database for real-time synchronization. After you select tables, click Preview to view all matched tables in the Select/Exclude Table Preview dialog box. In the dialog box, you can search for tables by keyword and delete tables individually or in batches.

  Batch Select/Batch Exclude: If you select Batch Select, multiple selected tables in the current database are synchronized in real time. If you select Batch Exclude, multiple selected tables in the current database are not synchronized in real time.

Parameter

Description

Data Source Configuration

Data Source Type

Select Kafka.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a Kafka data source.

Source topic

Select the topic of the source data. You can enter a keyword in the topic name to perform a fuzzy search.

Data format

Only Canal JSON is supported. Canal JSON is a format compatible with Canal. Data is stored in Canal JSON format.

Key Type

The key type for Kafka, which determines the key.deserializer configuration when initializing KafkaConsumer. Only STRING is supported.

Value Type

The value type for Kafka, which determines the value.deserializer configuration when initializing KafkaConsumer. Only STRING is supported.

Consumer Group ID (optional)

Enter the ID of the consumer group. The consumer group ID is used to report the status offset.

Sync Rule Configuration

Table List

Enter the names of the tables to be synchronized. Separate multiple table names with line breaks. The value can be up to 1,024 characters in length.

Table names can be in one of the following three formats: tablename, db.tablename, or schema.tablename.

Parameter

Description

Data Source Configuration

Data Source Type

Select Hive.

Datasource

You can only select a Hive data source in Hudi table format. You can also click New to create a data source on the Datasource page. For more information, see Create a Hive data source.

Sync Rule Configuration

Sync Solution

Only Real-time Incremental is supported. Collects incremental changes from the source database and writes them to the downstream destination database in real time in the order they occur.

Select Table

Select a single table for real-time synchronization.

Parameter

Description

Data Source Configuration

Data Source Type

Select PolarDB.

Datasource

You can only select a PolarDB data source of the MySQL database type. You can also click New to create a data source on the Datasource page. For more information, see Create a PolarDB data source.

Time Zone

The time zone configured for the selected data source.

Sync Rule Configuration

Sync Solution

Select Real-time Incremental or Real-time Incremental + Full. The default value is Real-time Incremental.

• Real-time Incremental: Collects incremental changes from the source database and writes them to the downstream destination database in the order they occur.

• Real-time Incremental + Full: Imports the full data from the source database at one time, and then collects and writes incremental changes to the downstream destination database in the order they occur.

Selection Method

You can select Entire Database, Select Tables, or Exclude Tables.

• Entire Database: Synchronizes all tables in all databases under the selected data source.

• Select Tables/Exclude Tables: Selects some tables in the current database for real-time synchronization. After you select tables, click Preview to view all matched tables in the Select/Exclude Table Preview dialog box. In the dialog box, you can search for tables by keyword and delete tables individually or in batches. You cannot delete tables if you use Regex Match.

  • Batch Select/Batch Exclude: If you select Batch Select, multiple selected tables in the current database are synchronized in real time. If you select Batch Exclude, multiple selected tables in the current database are not synchronized in real time.

  • Regex Match: Enter a regular expression for table names in the Regular Expression input box. Java regular expressions are supported, such as schemaA.*|schemaB.*.

Parameter

Description

Data Source Configuration

Data Source Type

Select MaxCompute.

Datasource

Select a destination data source. You can select a MaxCompute data source and project. You can also click New to create a data source on the data source page. For more information, see Create a MaxCompute data source.

Sink Table Creation Configuration

New Table Type

Select Standard Table or Delta Table. The default value is Standard Table.

If you select Delta Table and set the sink table creation method to Auto-create table, a MaxCompute Delta table is created. Additional fields are not used when creating a Delta table.

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Partition Format

If you select standard table as the table type, the partition format supports only Multi-partition. If you select Delta table as the table type, the partition format supports No Partition or Multi-partition.

Partition Interval

If you set Partition Format to No Partition, you cannot configure the partition interval. If you set Partition Format to Multiple Partitions, you can set the partition interval to hour or day.

Parameter

Description

Data Source Configuration

Data Source Type

Select MySQL.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a MySQL data source.

Time Zone

The time zone configured for the selected data source.

Sink Table Creation Configuration

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Parameter

Description

Data Source Configuration

Data Source Type

Select Microsoft SQL Server.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a Microsoft SQL Server data source.

Time Zone

The time zone configured for the selected data source.

Sink Table Creation Configuration

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Parameter

Description

Data Source Configuration

Data Source Type

Select Oracle.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create an Oracle data source.

Time Zone

The time zone configured for the selected data source.

Sink Table Creation Configuration

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Parameter

Description

Data Source Configuration

Data Source Type

Select Kafka.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a Kafka data source.

Destination Topic

The topic for the destination data. You can select Single Topic or Multiple Topics. If you select Single Topic, select a destination topic. You can enter a keyword in the topic name to search. If you select Multiple Topics, you can configure topic name transform and topic parameters.

• Single Topic: All table messages are written to the same topic.

• Multiple Topics: A topic with the same name is created for each table.

Data format

Set the storage format for the written data. Supported formats include DTS Avro and Canal Json.

• DTS Avro: A data serialization format that converts data structures or objects into a format that is easy to store or transmit.

• Canal Json: A format compatible with Canal. Data is stored in Canal JSON format.

Destination topic configuration

Topic Name Transform

Click Configure Topic Name Transform. In the Configure Topic Name Transform Rules dialog box, configure Topic Name Transform Rules and a prefix and suffix for the topic name.

• Topic Name Transform Rules: Click New Rule to add a rule. You must enter the Source Table String to Replace and Destination Topic Replacement String. Neither can be empty, and the Destination Topic Replacement String can only contain letters, digits, and underscores (_) and be up to 32 characters in length.

• Prefix and suffix for the topic name: Can contain letters, digits, and underscores (_). The length cannot exceed 32 characters.

Topic Parameters

Additional parameters for creating a topic. The format is key=value. Separate multiple parameters with line breaks.

Parameter

Description

Destination Data

Data Source Type

Select DataHub.

Datasource

Select a destination data source.

The system provides a shortcut to create a data source. You can click New to create a DataHub data source on the data source page. For more information, see Create a DataHub data source.

Destination Topic Creation Method

You can select New Topic or Use Existing Topic.

• New Topic: Manually enter the destination topic to create it.

• Use Existing Topic: Use an existing topic in the destination database. Make sure that the topic's schema is consistent with the format of the sync message. Otherwise, the sync task will fail.

Destination Topic

• Target Topic Creation Method is New Topic.

  Manually enter the Destination Topic. The Destination Topic must start with a lowercase letter and contain 3 to 64 digits, letters, or underscores (_).

  After you enter the topic, click Validate to check if the topic already exists in the destination database.

  • If the topic does not exist in the destination database, it is automatically created. The schema is the schema of the sync message, and the default lifecycle is 7 days.

  • If the topic already exists in the destination database, make sure that the topic's schema is consistent with the schema of the sync message. Otherwise, the task will fail.

• Target Topic Creation Method is Use Existing Topic.

  Click the drop-down list to select an existing topic in the destination database. If there are many topics, you can enter a topic name to search for the desired topic.

Parameter

Description

Data Source Configuration

Data Source Type

Select Databricks.

Datasource

Select a destination data source. You can select a Databricks data source and project. You can also click New to create a data source on the data source page. For more information, see Create a Databricks data source.

Time Zone

Time-formatted data is processed based on the current time zone. By default, this is the time zone configured in the selected data source and cannot be modified.

Sink Table Creation Configuration

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Partition Format

You can select No Partition or Multiple Partitions.

Partition Interval

If you set Partition Format to No Partition, you cannot configure the partition interval. If you set Partition Format to Multiple Partitions, you can set the partition interval to hour or day.

Parameter

Description

Data Source Configuration

Data Source Type

Select SelectDB.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a SelectDB data source.

Sink Table Creation Configuration

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Parameter

Description

Data Source Configuration

Data Source Type

Set Data Source Type to Hive.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see Create a Hive data source.

Sink Table Creation Configuration

Data lake table format

You can select None, Hudi, Iceberg, or Paimon.

• None: Writes data and creates tables as standard Hive tables.

• Hudi: Writes data and creates tables in Hudi format. You can select Hudi only when the Hive data source version is CDP7.x Hive 3.1.3.

• Iceberg: Writes data and creates tables in Iceberg format. You can select Iceberg only when the Hive data source version is EMR5.x Hive 3.1.x.

• Paimon: Writes data and creates tables in Paimon format. You can select Paimon only when the Hive data source version is EMR5.x Hive 3.1.x.

Hudi Table Type/Paimon Table Type

For Hudi Table Type, you can select MOR (merge on read) or COW (copy on write).

For Paimon Table Type, you can select MOR (merge on read), COW (copy on write), or MOW (merge on write).

Table Creation Execution Engine

You can select Hive or Spark. If you select a data lake table format, Spark is selected by default.

• Hive: Uses the Hive engine to create tables. The table creation syntax is Hive syntax.

• Spark: Uses the Spark engine to create tables. The table creation syntax is Spark syntax. You can select Spark only when Spark is enabled for the Hive data source.

  Note

  When Data lake table format is set to Paimon, only Spark is supported as the table creation execution engine.

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Partition Format

You can select Single Partition, Multiple Partitions, or Fixed Partition.

Partition Interval

The default value is hour. You can also select day. Click the icon next to the partition interval to view partition setting details.

• Single Partition:

  • hour: A hash partition (yyyyMMddhh) with the partition key column name ds.

  • Day: Displays the hash partition (yyMMdd) with the partition key column named ds.

• Multiple Partitions:

  • hour: Four levels of partitions: yyyy, mm, dd, and hh.

  • day: Three levels of partitions: yyyy, mm, and dd.

Partition Value

Enter a fixed partition value, for example, 20250101.

Parameter

Description

Data Source Configuration

Data Source Type

Select Hologres.

Datasource

Select a destination data source. You can select a Hologres data source and project. You can also click New to create a data source on the data source page. For more information, see Create a Hologres data source.

Schema

Select a destination schema.

Sink Table Creation Configuration

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Parameter

Description

Data Source Configuration

Data Source Type

Select StarRocks.

Datasource

Select a data source. You can also click New to create a data source on the Datasource page. For more information, see.

Sink Table Creation Configuration

Table Name Transform

Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

Click Configure Table Name Transform to open the Configure Table Name Transform Rules dialog box.

• Replace String: Click New Rule to add a rule. Configure Source Table String to Replace and Sink Table Replacement String. You can add up to 5 rules.

• Table Name Prefix/Suffix: Cannot be empty. Can contain only letters, digits, and underscores (_). The length cannot exceed 32 characters.

Block

Description

① View additional fields

During real-time incremental synchronization, additional fields are automatically added when a table is auto-created to facilitate data use. Click View additional fields to view the fields. In the Additional Fields dialog box, you can view the currently added fields.

Click View DDL for Adding Fields to view the DDL statement for adding the additional fields.

② Search and filter area

Search by Source Table and Sink Table Name. To quickly filter sink tables, click the icon at the top and filter by Mapping Status and Creation Method.

③ Add global fields, Refresh mapping

• Add global fields

  Click Add global fields to add global fields in the Add Global Fields dialog box.

  • Name: The name of the global field.

  • Type: Supported data types are String, Long, Double, Date, and Boolean.

  • Value: The value of the global field.

  • Description: A description of the field.

  Note

  • If a field is added both globally and for a single table, only the single-table field takes effect.

  • Currently, only constants can be added.

  • Global fields only take effect for sink tables that are set to Auto-create table.

  • Adding global fields is not supported when the source data source type is Kafka.

• Refresh mapping

  To refresh the sink table configuration list, click Refresh mapping.

  Important

  • If the sink table configuration already has content, reselecting the data source type and data source will reset the sink table list and mapping. Proceed with caution.

  • You can click to refresh again at any time during the refresh process. Each time you click Refresh mapping, only the configured global fields are saved. Other information, including the sink table creation method, sink table name, and deletion records, is not saved.

  • When the source data source type is Kafka, clicking Refresh mapping will map based on the table list in the Sync Rule Configuration. An error is reported if a table does not exist.

④ Destination database list

The destination database list includes Serial Number, Source Table, Mapping Status, Sink Table Creation Method, and Sink Table Name. You can also add fields, view fields, refresh, or delete a sink table.

• Mapping Status:

  • Completed: Mapping is completed normally.

  • Incomplete: The status was modified, but the mapping was not refreshed.

  • Mapping: Waiting for mapping or in the process of mapping.

  • Abnormal: A data source or internal system error exists.

  • Failed: The destination partitioned table is inconsistent with the partition set for the real-time task.

  • Alerting: The source and sink tables may have incompatible data types.

• Sink Table Creation Method has three options:

  • If a table with the same name as the source table exists in the destination database, the creation method is "Use existing table", and this table is used as the sink table by default. To change to "Auto-create table", add a table name transform rule or a prefix/suffix and remap.

  • If no table with the same name is found in the destination database, the creation method defaults to "Auto-create table". You can also change it to "Use existing table" and select an existing table for synchronization.

  • Only tables that are auto-created support adding fields or custom DDL table creation. Global fields also only take effect for auto-created tables.

  Note

  • When the destination data source type is Hive:

    • During auto-creation, if the data lake table format is None, a standard Hive table is created. Otherwise, a table of the selected format is created. Hudi and Iceberg are currently supported.

    • During custom creation, if the data lake table format is None, use the DDL for a standard Hive table. Otherwise, use the DDL for the selected table format. Hudi and Iceberg are currently supported.

  • When the source data source type is Kafka, the sink table creation method only supports Use existing table.

  • When the destination data source type is SelectDB, if the source table has no primary key, a Duplicate table is created during auto-creation. If the source table has a primary key, a Unique table is created.

  • If Partition Format is set to Single Partition or Fixed Partition and Sink Table Creation Method is set to Use existing table, the system automatically checks if the sink table partition matches the partition settings. An error is reported if it does not match.

  • When the destination data source is StarRocks, auto-creation creates a StarRocks table. If the source table has no primary key, a Duplicate table is created. If the source table has a primary key, a Primary table is created.

• Sink Table Name: Sink table names can contain only letters, digits, and underscores (_). If a source table name contains other characters, you must configure a table name transform rule.

  When the destination data source type is MaxCompute: If Sink Table Creation Method is Auto-create table and New Table Type is Delta Table, the icon is displayed next to the sink table name, indicating that a Delta table will be created. If Sink Table Creation Method is Use existing table and the user selects a Delta table from the sink table list, the icon is also displayed next to the sink table name, indicating that it is a Delta table.

• Actions:

  • Custom table creation: You can create a table by adding fields or using DDL. After enabling custom table creation, global fields no longer take effect.

    Note

    • Added fields are only displayed in the actions column for auto-created tables.

    • You cannot modify an existing sink table (a table with the creation method "Use existing table").

  • View fields: View the fields and types of the source and sink tables.

  • Refresh: Remap the source and sink tables.

  • Delete: Deleting a source table cannot be undone.

⑤ Batch operations

You can Delete sink tables in batches.

Block

Description

① Search and filter area

Search by Source Table and Destination Topic Name. To quickly filter sink tables, click the icon at the top and filter by Mapping Status and Destination Topic Creation Method.

② Refresh mapping

To refresh the sink table configuration list, click Refresh mapping.

③ List

The list includes Serial Number, Source Table, Mapping Status, Destination Topic Creation Method, and Destination Topic Name. You can also delete a sink table.

• Destination Topic Creation Method: If the destination topic already exists, the creation method is Use Existing Topic. If the destination topic does not exist, the creation method is Auto-create Topic.

  When a topic is auto-created, the system creates it based on the generated destination topic name and topic parameters.

• Mapping Status: Only checks if the destination topic exists.

• Delete: Deletes the corresponding row. This operation cannot be undone.

④ Batch operations

You can Delete sink tables in batches.