有一个问题，我可以如何确认Flink CDC任务消费 binlog 的延迟呢？就像 kafka 的
问题1:有一个问题，我可以如何确认Flink CDC任务消费 binlog 的延迟呢？就像 kafka 的 lag一样？大家有什么方法么？这个的确可以。 问题2:这个是看 debezium 的指标么？
展开
收起
1
条回答
写回答
写回答
-
回答1:一般cdc延迟很小的，除非你做了一些join复杂操作，我会比对source的sink端的 数据创建时间，或者其他一些指标去metrics看 回答2:这是flink的指标，此回答整理自钉群“Flink CDC 社区”
2023-06-11 16:54:25赞同 展开评论 打赏
问答分类：
相关产品：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
热门讨论
热门文章
FFA 2024 大会门票免费送！AI时代下大数据技术未来路在何方？
849
P人出游，你是否需要一个懂你更懂规划的AI导游呢？来搭建专属文旅问答机器人吧
1682
虚拟机占用内存特别大，90多个G,网上各种方法都试过了，怎么解决这个问题
1351
Slot request bulk is not fulfillable，20以上job同时部署失败
691
数据来源：com.alibaba.fastjson.JSONException: syntax er
5519
大佬，Caused by: java.lang.ClassNotFoundException: or
429
Dataphin和 Dataworks 有啥区别呢？
1832
dataworks里面的stg层、ods层、dwd层、dws层、是怎么分层的呢？
2583
兄弟们啊，同步中DI、RI到底什么意思，是什么的缩写？
331
FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
3499
展开全部
推荐系统之冷启动问题
5709
网鱼网咖-利用数加快速搭建大数据平台，极致洞察，为客户带来从所未有的体验。
5773
在 Cloudera Data Flow 上运行你的第一个 Flink 例子
2806
DataWorks智能数据建模全面公测开始啦！
4258
DataWorks售前咨询
8452
什么是HTTP代理？HTTP代理的作用？HTTP代理怎么设置？
7271
Java“找不到符号” 错误怎么查找解决
1063
Ubuntu 报错：System has not been booted with systemd as init system (PID 1). Can‘t operate.
1723
视觉 注意力机制——通道注意力、空间注意力、自注意力
4337
实时计算 Flash – 兼容 Flink 的新一代向量化流计算引擎
611
展开全部
相关课程
更多
相关文章
相关电子书
更多
