Flink CDC这个参数代码里不支持？

这是增量快照的，你导包不对 ，此回答整理自钉群“Flink CDC 社区”

Flink CDC不支持scan.startup.mode参数。

Flink CDC 支持的参数代码如下：

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.catalog.hive.HiveCatalog;
import org.apache.flink.table.descriptors.Schema;
import org.apache.flink.table.descriptors.TableDescriptor;
import org.apache.flink.table.descriptors.connectors.DebeziumCatalogConnector;
import org.apache.flink.table.descriptors.types.RowType;

public class FlinkCDCExample {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

        HiveCatalog hiveCatalog = new HiveCatalog("default", "localhost", 31010, null, null);
        tableEnv.registerCatalog("hive", hiveCatalog);
        tableEnv.useCatalog("hive");

        TableDescriptor tableDescriptor = TableDescriptor.builder()
                .name("your_table_name")
                .schema(Schema.builder().field("id", DataTypes.BIGINT()).field("name", DataTypes.STRING()).build())
                .connector(DebeziumCatalogConnector.newBuilder()
                        .type("mysql")
                        .version("8.0.26")
                        .hostname("your_mysql_host")
                        .port(3306)
                        .username("your_mysql_username")
                        .password("your_mysql_password")
                        .databaseName("your_mysql_database")
                        .tableNamePrefix("your_mysql_table_prefix")
                        .build())
                .build();

        tableEnv.createTemporaryView("your_table_name", tableDescriptor);

        tableEnv.toAppendStream(tableDescriptor, RowType.of(DataTypes.BIGINT(), DataTypes.STRING()))
                .print();

        env.execute("Flink CDC Example");
    }
}

请将上述代码中的 your_table_name、your_mysql_host、your_mysql_username、your_mysql_password、your_mysql_database 和 your_mysql_table_prefix 替换为实际的值。