Flink CDC中使用DataStream API 可以配置 scan.incremental.？

Flink CDC 使用 DataStream API 可以通过 scan.incremental.timestamp.column 配置增量读取的列。该列必须是时间戳列，且只能有一个时间戳列。

以下是一个使用 DataStream API 配置增量读取的示例代码：

import io.debezium.connector.mysql.MySqlConnector

val table = TableSource.fromCdc(
connector = MySqlConnector.class,
database = "database",
table = "table",
scan.incremental.timestamp.column = "ts"
)
在这种配置下，Flink CDC 会从 ts 列中读取数据，并将数据转换为 DataStream。