flinkcdc入门
时间: 2023-09-01 09:13:10 浏览: 136
flinkcdcd上傳文件(2)
要入门Flink CDC,你可以按照以下步骤进行操作:
1. 首先,启动开发的flink-cdc代码。你可以使用命令`bin/flink run -c com.atguigu.FlinkCDC flink-1.0-SNAPSHOT-jar-with-dependencies.jar`来启动程序。
2. 接下来,你可以测试mysql数据库的新增数据。通过向数据库表tab1中插入数据,你可以观察到flink-cdc实时获取到新增的数据。
3. 在了解Flink CDC时,你需要了解基于查询和基于Binlog两种方式的区别。基于查询的CDC使用开源产品Sqoop、Kafka JDBC Source来执行,而基于Binlog的CDC则使用Canal、Maxwell、Debezium等开源产品。这两种方式在执行模式、延迟性、是否可以捕获所有数据变化、是否增加数据库压力等方面存在差异。
通过以上步骤,你可以初步了解Flink CDC的入门知识。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [flink-cdc入门使用](https://blog.csdn.net/myself_ning/article/details/125651390)[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_1"}}] [.reference_item style="max-width: 50%"]
- *2* *3* [Flink CDC 快速入门](https://blog.csdn.net/mengxianglong123/article/details/124449805)[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_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]
阅读全文