问答 2023-12-13 来自:开发者社区

Flink CDC现在从Kafka读取消息显示source背压100这种应该怎样分析?

Flink CDC现在从Kafka读取消息显示source背压100这种应该怎样分析,具体应该从哪里看才能得出结论是Kafka压力太大发送的量小了还是集群本身的资源不够了?都是Kafka读取的,web ui的source都是黑的如何分析背压原因,该从哪入手?每次读取才几百?

问答 2023-10-03 来自:开发者社区

flink cdc 消费数据写入Kafka,实际写入Kafka中 却没有source对象是什么原因?

flink cdc 消费数据写入Kafka,我用的debezium-json格式的数据,但是实际写入Kafka中 却没有source对象是什么原因?

问答 2023-05-23 来自:开发者社区

请教 Flink CDC中kafka source 这里差了很久时间 一般是什么原因?

请教 Flink CDC中kafka source 这里差了很久时间 一般是什么原因? 数据倾斜为什么会导致这个问题呢?

问答 2023-01-09 来自:开发者社区

有没有知道cdc 从Oracle到kafka,checkpoint 导致source背压怎么解决吗?

有没有大佬知道cdc 从Oracle到kafka,checkpoint 导致source背压怎么解决吗,cdc的source并行度只能设置为1。

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注