flinkcdc使用教程

在学习Flink CDC的过程中，作者主要将重点记录下来作为自己的学习笔记，方便快速上手进行开发。
Flink CDC是指Flink Change Data Capture，主要用于实时数据的捕获和处理。它可以根据数据源的变化，实时捕获新增、更新或删除的数据，并将这些变化应用到目标系统中。
在学习Flink CDC的教程中，可以通过两种方式进行实操，分别是使用DataStream和FlinkSQL。使用DataStream可以更直观地感受Flink CDC的强大功能，而使用FlinkSQL则更加方便和灵活。具体的教程可以参考链接：https://www.bilibili.com/video/BV1wL4y1Y7Xu?p=13。
对于启动Flink CDC的命令，可以使用如下的命令进行启动：bin/flink run -m hadoop102:8081 -c com.tianyi.FlinkCDC ./flink-cdc-1.0-SNAPSHOT-jar-with-dependencies.jar。其中，hadoop102:8081是Flink集群的地址和端口号，com.tianyi.FlinkCDC是启动类的名称，./flink-cdc-1.0-SNAPSHOT-jar-with-dependencies.jar是Flink CDC应用的jar包。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [Flink-CDC实践（含实操步骤与截图）](https://blog.csdn.net/hshudoudou/article/details/125054351)[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^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]