建站
咨詢
售后
建站咨詢
新聞中心
是的，F(xiàn)link CDC 高版本取消了創(chuàng)建數(shù)據(jù)源的方式，改為使用 Table API 或 SQL API 來(lái)操作數(shù)據(jù)源。
Flink CDC 中高版本 MySQL CDC 取消創(chuàng)建數(shù)據(jù)源的方式
成都創(chuàng)新互聯(lián)是一家專注于成都做網(wǎng)站、網(wǎng)站設(shè)計(jì)與策劃設(shè)計(jì),成武網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)十年,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:成武等地區(qū)。成武做網(wǎng)站價(jià)格咨詢:18982081108
單元表格：
| 功能/特性 | 舊版本 | 新版本 |
| 創(chuàng)建數(shù)據(jù)源方式 | 使用 DebeziumSourceFunction | 不再支持，改為使用 DebeziumDeserializationSchema |
| 數(shù)據(jù)源連接配置 | 在 DebeziumSourceFunction 中進(jìn)行配置 | 在 Flink SQL DDL 中進(jìn)行配置 |
| 數(shù)據(jù)源初始化 | 在 DebeziumSourceFunction 中進(jìn)行初始化操作 | 在 Flink SQL DDL 中進(jìn)行初始化操作 |
| 數(shù)據(jù)源關(guān)閉 | 在 DebeziumSourceFunction 中進(jìn)行關(guān)閉操作 | 在 Flink SQL DDL 中進(jìn)行關(guān)閉操作 |
在 Flink CDC（Change Data Capture）中，高版本的 MySQL CDC（MySQL Change Data Capture）取消了使用 DebeziumSourceFunction 創(chuàng)建數(shù)據(jù)源的方式，取而代之的是，使用 DebeziumDeserializationSchema。
具體來(lái)說(shuō)，舊版本中，我們可以通過(guò)實(shí)現(xiàn) DebeziumSourceFunction 來(lái)創(chuàng)建數(shù)據(jù)源，并在該函數(shù)中進(jìn)行連接配置、初始化和關(guān)閉等操作，而在新版本中，這些操作需要在 Flink SQL DDL（Data Definition Language）中進(jìn)行配置和執(zhí)行。
以下是使用新版本的步驟：
1、定義表結(jié)構(gòu)：我們需要在 Flink SQL DDL 中定義要使用的表結(jié)構(gòu)，這包括表名、字段名、字段類型等信息。
```sql
CREATE TABLE my_table (
id BIGINT,
name STRING,
age INT,
...
) WITH (...);
```
2、配置數(shù)據(jù)源連接：接下來(lái)，我們需要在 Flink SQL DDL 中配置數(shù)據(jù)源的連接信息，這包括數(shù)據(jù)庫(kù) URL、用戶名、密碼等。
```sql
SET 'debezium.connector.class' = 'io.debezium.connector.mysql.MySqlConnector';
SET 'debezium.offset.storage' = 'org.apache.flink.connector.debezium.OffsetBackingStore';
SET 'debezium.offset.storage.file.filename' = '/path/to/offset/storage/file';
SET 'debezium.database.hostname' = 'localhost';
SET 'debezium.database.port' = '3306';
SET 'debezium.database.user' = 'root';
SET 'debezium.database.password' = 'password';
SET 'debezium.database.server.id' = '85740';
SET 'debezium.database.server.name' = 'my_server';
SET 'debezium.database.whitelist' = 'my_db,other_db';
```
3、初始化數(shù)據(jù)源：我們可以使用 Flink SQL DDL 中的其他語(yǔ)句來(lái)初始化數(shù)據(jù)源，可以使用 CREATE TABLE AS SELECT 語(yǔ)句將已有的數(shù)據(jù)導(dǎo)入到新表中。
```sql
CREATE TABLE my_table_copy AS SELECT * FROM my_source_table;
```
通過(guò)以上步驟，我們可以在新版本的 Flink CDC 中使用 DebeziumDeserializationSchema 來(lái)創(chuàng)建和管理數(shù)據(jù)源，這種方式更加簡(jiǎn)潔和靈活，并且與 Flink SQL DDL 集成得更好。
相關(guān)問(wèn)題與解答：
1、Q: 新版本的 Flink CDC 中如何關(guān)閉數(shù)據(jù)源？
A: 在新版本的 Flink CDC 中，關(guān)閉數(shù)據(jù)源的操作需要在 Flink SQL DDL 中進(jìn)行，可以使用 DROP TABLE 語(yǔ)句來(lái)刪除對(duì)應(yīng)的表，從而關(guān)閉數(shù)據(jù)源。DROP TABLE my_table;，這將釋放相關(guān)資源并關(guān)閉數(shù)據(jù)源。
2、Q: 我可以在新版本的 Flink CDC 中使用舊版本的 DebeziumSourceFunction 嗎？
A: 不可以，在新版本的 Flink CDC 中，取消了對(duì)舊版本的 DebeziumSourceFunction 的支持，建議使用新版本提供的 DebeziumDeserializationSchema，它提供了更好的集成和更簡(jiǎn)潔的配置方式。
本文題目：FlinkCDC里高版本的mysqlcdc取消掉這種創(chuàng)建數(shù)據(jù)源的方式了嗎？
地址分享：http://fisionsoft.com.cn/article/dpcohic.html
