[FLINK-28487] Introduce configurable RateLimitingStrategy for Async Sink

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Done
• Fix Version/s: 1.16.0
• Component/s: Connectors / Common
• Labels: pull-request-available

Release Note

Supports configurable RateLimitingStrategy for the AsyncSinkWriter. This change allows sink implementers to change the behaviour of an AsyncSink when requests fail, for a specific sink. If no RateLimitingStrategy is specified, it will default to current default of AIMDRateLimitingStrategy.

• Assignee: Hong Liang Teoh
• Reporter: Hong Liang Teoh
• Created: 11/Jul/22 08:58
• Updated: 14/Sep/22 07:44
• Resolved: 09/Aug/22 15:25

Description

Introduce a configurable RateLimitingStrategy to the AsyncSinkWriter.

This change will allow sink implementers using AsyncSinkWriter to configure their own RateLimitingStrategy instead of using the default AIMDRateLimitingStrategy.

See FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink.

 

Issue Links

• fixes: FLINK-28027 Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy
• links to: GitHub Pull Request #20245