为什么许多输出流出现背压



我的flink作业现在有60多个输出流,每个流的实现都很简单但是,为什么在kafka源操作符中会出现背压。

在此处输入图像描述我的工作图

在此处输入图像描述卡夫卡源背压

基本上,您的作业在物理上不可能比最慢接收器的吞吐量运行得更快。

最新更新