[CAMEL-21526] camel-aws - Unable to set Timestamp in query parameters to initialize iterator of AT_TIMESTAMP type for AWS Kinesis component

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 3.20.9, 4.9.0
• Fix Version/s: 4.x
• Component/s: camel-aws2-kinesis
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Artem
• Created: 2 days ago 14:51
• Updated: 2 days ago 15:17

Description

Problem
In AWS Kinesis, the iteratorType=AT_TIMESTAMP is an option that allows you to start consuming records from a stream starting at a specific point in time.
To use iteratorType=AT_TIMESTAMP, we need to request the GetShardIterator from AWS Kinesis API and specify Timestamp parameter for that request.
This message timestamp parameter must be set initially when we create AWS Kinesis Consumer.
But in current Camel implementation unfortunately we don't have such ability.
You can see in docs (https://camel.apache.org/components/next/aws2-kinesis-component.html) that all we can is to set CamelMessageTimestamp message header. This way is not suitable for initial setup of the iterator.
Apparently, the most suitable way is to set the timestamp in the URL options (like for sequenceNumber).

Steps to reproduce
You can use the example project attached to this bug.

Solution
Possible solution you can find here: https://github.com/apache/camel/commit/8772c5f2d4a57633447d2717dff53d87555b0e3b