[BEAM-2469] Handling Kinesis shards splits and merges

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.4.0
• Component/s: io-java-kinesis
• Assignee: Paweł Kaczmarczyk
• Reporter: Paweł Kaczmarczyk
• Created: 19/Jun/17 12:56
• Updated: 16/May/20 13:47
• Resolved: 30/Jan/18 13:50

Description

Kinesis stream consists of shards that allow for capacity scaling. In order to increase/decrease the capacity shards have to be split/merged together. Such operations are currently not handled properly and will end with errors.

Issue Links

• links to: GitHub Pull Request #4243