有人遇到过flink消费kafka性能不足的问题么?现在我们kafka的topic有50个分区,每年350w的数据量,我们做了黑洞测试,就单纯消费一下数据,应用一直积压。调kafka的消费参数无用,2分钟的checkpoint读数据,写入黑洞。有什么思路么?每秒350w。
有人遇到过flink消费kafka性能不足的问题么?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
有人遇到过flink消费kafka性能不足的问题么?现在我们kafka的topic有50个分区,每年350w的数据量,我们做了黑洞测试,就单纯消费一下数据,应用一直积压。调kafka的消费参数无用,2分钟的checkpoint读数据,写入黑洞。有什么思路么?每秒350w。