flinkcdc binary
时间: 2023-09-02 13:09:22 浏览: 123
Flink CDC是一个用于将数据库变更数据流导入Apache Flink的工具。它的底层是基于Debezium,并且在架构上是单节点,因此它只支持单并发。在处理大规模表时,由于读取时间可能需要几小时甚至几天,无法通过增加资源来提高作业速度。
在Flink CDC 1.x版本中,可以选择不加锁,以满足大多数场景的需求,但这样会牺牲一定的数据准确性。默认情况下,Flink CDC 1.x会添加全局锁,以保证数据的一致性,但也存在可能导致数据被阻塞的风险。
在建立与数据库的连接时,需要发送BINLOG_DUMP指令,该指令包括多个参数,如写入命令编号、要开始的binlog位置、binlog标志、从库的server id和binlog文件名等。这些参数用于告知数据库服务器从指定的binlog位置开始传输变更数据。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [【硬刚大数据】大数据同步工具之FlinkCDC/Canal/Debezium对比](https://blog.csdn.net/u013411339/article/details/120917907)[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 ]
阅读全文