[CAMEL-20250] camel-kinesis: resume API fails to resume properly

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.21.3, 4.3.0
• Fix Version/s: 4.4.0
• Component/s: camel-aws2-kinesis
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Otavio Rodolfo Piske
• Created: 18/Dec/23 13:23
• Updated: 19/Dec/23 10:41
• Resolved: 19/Dec/23 10:41

Description

Quoting https://github.com/abendton the pull request #12462:

• the shardId is not available in the exchange. The shardId is required to properly configure the GetShardIteratorRequest in the resume scenario (AWS doc)
• the KinesisResumeAdapter API does not allow to pass in the shardId.
• When consuming multiple shards the KinesisResumeAdapter will potentially be used by multiple threads concurrently. With the current API, this could cause concurrency issues

Issue Links

• links to: GitHub Pull Request #12462