[BEAM-10816] Not possible to implement own RateLimitPolicy

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.23.0
• Fix Version/s: 2.25.0
• Component/s: io-java-kinesis
• Assignee: Alexey Romanenko
• Reporter: Sebastian Graca
• Created: 26/Aug/20 13:35
• Updated: 03/May/21 16:57
• Resolved: 03/May/21 16:57

Description

It's not possible to provide custom implementation of RateLimitPolicy because KinesisClientThrottledException class which is the type of the parameter of onThrottle method is package private.

This makes it impossible to implement onThrottle method outside of org.apache.beam.sdk.io.kinesis package.

Issue Links

• links to: GitHub Pull Request #12862