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

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

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

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

Flink这种背压怎么搞?先写入到kafka缓存 在从kafka拉出来到数据库?

Flink这种背压怎么搞?先写入到kafka缓存 在从kafka拉出来到数据库?

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

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

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

问答 2022-08-02 来自:开发者社区

kafka是其他部门的,如果是在kafka source算子那有背压,怎么加以区分呢?

kafka是其他部门的,如果是在kafka source算子那有背压,怎么加以区分呢?

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

产品推荐

消息队列

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等