[
https://issues.apache.org/jira/browse/CAMEL-9443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15068353#comment-15068353
]
Andrew Wheat commented on CAMEL-9443:
-------------------------------------
# list streams with the table name to get the stream ARN.
# describe stream with the stream ARN to get the list of shards
# Select a shard (latest, next when walking some history)
# get a shard iterator
## use the shard iterator to call getRecords
## use the result of getRecords to populate the next shard iterator
## Repeat getRecords until the API returns a null shard iterator
# Repeat until the heat-death of the universe.
> Camel Component for DynamoDB Streams
> ------------------------------------
>
> Key: CAMEL-9443
> URL: https://issues.apache.org/jira/browse/CAMEL-9443
> Project: Camel
> Issue Type: New Feature
> Components: camel-aws
> Reporter: Andrew Wheat
> Priority: Minor
> Fix For: 2.17.0
>
>
> AS a user of DynamoDB
> I WANT a camel component for the change event feed
> SO THAT I can process the change events easily
> Given a DynamoDB table
> And the table has a stream configured
> When Camel starts
> Then my Processor gets Exchanges for each change event
> Shard Iterator Types to handle:
> * TRIM_HORIZON
> * LATEST
> * AT_SEQUENCE_NUMBER
> * AFTER_SEQUENCE_NUMBER
> See
> http://docs.aws.amazon.com/dynamodbstreams/latest/APIReference/API_GetShardIterator.html
> for definitions of these types.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
