flinkcdc sink
时间: 2023-09-03 13:12:35 浏览: 103
在Flink中,可以使用Flink CDC connector作为sink,将数据写入到其他系统中。Flink CDC connector可以直接在Flink中以非约束模式(流)使用,而不需要使用类似kafka之类的中间件中转数据。该组件可以捕获在一个或多个表中发生的所有变更,包括全量数据和增量变更数据。你可以使用Flink CDC connector来读取MySQL、PostgreSQL等数据库的数据,并将其写入到其他目标系统中。Flink CDC connectors组件已经在Flink社区中开发并开源,你可以在GitHub上找到该项目的开源地址:https://github.com/ververica/flink-cdc-connectors。<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/qq359605040/article/details/125446082)[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: 100%"]
[ .reference_list ]
阅读全文