flinkcdc 整库

整库同步是指将数据库中的所有表数据都同步到目标端的操作。在使用Flink CDC进行整库同步时，可以通过配置相关参数实现。

根据引用，选择了mysql-cdc作为Source端来实现整库同步到各Sink端。需要在引用中的代码中设置`table-name`参数为要同步的所有表的名称，以逗号分隔。例如，如果要同步数据库中的bigdata库中的products和orders表，可以将`table-name`设置为`bigdata\.products,bigdata\.orders`。

此外，还需要在sink库中创建相应的表，以便将数据写入目标端。这一步骤在引用中提到，要在sink库中先创建好相应的表。

最后，执行CDC作业即可开始整库同步的过程。在引用中的代码中，通过执行`EXECUTE CDCSOURCE`命令来启动CDC作业。该命令将使用mysql-cdc作为连接器连接到源端数据库，并将数据写入到指定的Kafka主题中。

总结起来，使用Flink CDC进行整库同步的步骤包括：
1. 设置`table-name`参数为要同步的所有表的名称。
2. 在sink库中创建相应的表。
3. 执行CDC作业，将数据从源端同步到目标端。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *3* [Dinky实践系列之FlinkCDC整库实时入仓入湖](https://blog.csdn.net/mars275173972/article/details/128551989)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT0_1"}}] [.reference_item style="max-width: 50%"]
- *2* [Flink CDC整库同步（多表异构同步）](https://blog.csdn.net/qq_36062467/article/details/128117647)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT0_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]