当前位置:网站首页>flink cdc怎么指定位点,从某个位点开始消费mysql的Binlog?
flink cdc怎么指定位点,从某个位点开始消费mysql的Binlog?
2022-08-04 15:42:00 【阿里云问答】
flink cdc怎么指定位点,从某个位点开始消费mysql的Binlog?
采纳答案1:
新版本的是不支持的,2.0之前的版本可以支持指定binlog消费.startupOptions(StartupOptions.specificOffset("",0))//文件名和消费位点(此答案整理自Flink CDC 社区)
边栏推荐
猜你喜欢
保证通信的机制有哪些
如何优雅的消除系统重复代码?
#夏日挑战赛# HarmonyOS 实现一个滑块验证
remote: Check Access Error, please check your access right or username and password!fatal: Authenti
线上一次JVM FullGC搞得整晚都没睡,彻底崩溃
Redis持久化操作
使用百度EasyDL实现森林火灾预警识别
Why, when you added a unique index or create duplicate data?
Many merchants mall system function and dismantling 24 - ping the strength distribution of members
Taurus.MVC WebAPI 入门开发教程2:添加控制器输出Hello World。
随机推荐
qt 复杂界面信号槽设计
"Research Report on the Development of Global Unicorn Enterprises in the First Half of 2022" released - DEMO WORLD World Innovation Summit ended successfully
H5 开发内嵌页面跨域问题
Xi'an Zongheng Information × JNPF: Adapt to the characteristics of Chinese enterprises, fully integrate the cost management and control system
有哪些好用的IT资产管理平台?
Pisanix v0.2.0 发布|新增动态读写分离支持
Manacher(求解最长回文子串)
numpy入门详细代码
GET 和 POST 请求的区别
云存储硬核技术内幕——(9) 相见时难别亦难
Semaphore 基本原理
JVM调优-GC基本原理和调优关键分析
Online Excel based on Next.js
Summary of some pytorch knowledge points that have been updated for a long time
Beginner crawler notes (collecting data)
界面组件DevExpress ASP.NET Core v22.1 - 增强数据导出功能
What is the difference between member variable and local variable
remote: Check Access Error, please check your access right or username and password!fatal: Authenti
Redis持久化操作
实战:10 种实现延迟任务的方法,附代码!