Flink初探之 动态限流

前言 最近一段时间，接触到公司flink代码，修改时遇到一个flink常见问题，就是上游Producer生产数据的效率大于下游Consumer的消费速度，所以查阅一些大佬的资料，将这一问题记录，后续系统学习flink的时候复习一下 Flink 流处理为什么需要网络流控？ 分析一个简单的 Flink 流任务，下图是一个简单的Flink流任务执行图：任务首先从 Kafka 中读取数据、 map 算子对

>>阅读原文<<