Hi all, I would like to open a discussion on FLIP-242: Introduce configurable CongestionControlStrategy for Async Sink.
The Async Sink was introduced as part of FLIP-171 [1], and implements a non-configurable congestion control strategy to reduce network congestion when the destination rejects or throttles requests. We want to make this configurable, to allow the sink implementer to decide the desired congestion control behaviour given a specific destination. This is a step towards reducing the barrier to entry to writing new async sinks in Flink! You can find more details in the FLIP-242 [2]. Looking forward to your feedback! [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink [2] https://cwiki.apache.org/confluence/display/FLINK/FLIP-242%3A+Introduce+configurable+CongestionControlStrategy+for+Async+Sink Regards, Hong
