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

["Andrea Cosentino (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CAMEL-21526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Andrea Cosentino reassigned CAMEL-21526:
----------------------------------------

    Assignee: Andrea Cosentino

> camel-aws - Unable to set Timestamp in query parameters to initialize iterator of AT_TIMESTAMP type for AWS Kinesis component
> -----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-21526
>                 URL: https://issues.apache.org/jira/browse/CAMEL-21526
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-aws2-kinesis
>    Affects Versions: 3.20.9, 4.9.0
>            Reporter: Artem
>            Assignee: Andrea Cosentino
>            Priority: Minor
>             Fix For: 4.x
>
>         Attachments: kinesis-timestamp-bug.zip
>
>
> *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



--
This message was sent by Atlassian Jira
(v8.20.10#820010)