Flink CDC中JdbcSink.sink中的sql 语句中的表 可以做为参数传入吗？

是的，你可以在Flink CDC中的JdbcSink.sink方法中将SQL语句中的表名作为参数传入。你可以使用Java的字符串格式化功能来实现这个需求。

以下是一个示例：

String sql = "INSERT INTO %s SELECT * FROM source_table";
String tableName = "target_table";
String formattedSql = String.format(sql, tableName);

JdbcSink<Row> jdbcSink = JdbcSink.sink(formattedSql, (ps, row) -> {
    ps.setInt(1, row.getInteger(0));
    ps.setString(2, row.getString(1));
    // ... set other fields
}, env.getConfig().getGlobalJobParameters());

在这个示例中，我们首先定义了一个包含占位符的SQL语句，然后使用String.format方法将表名替换为实际的表名。最后，我们将格式化后的SQL语句传递给JdbcSink.sink方法。

等等3.0这些你都不需要了，支持整库同步和schema evolution ，此回答整理自钉群“Flink CDC 社区”