[
https://issues.apache.org/jira/browse/CAMEL-19789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759623#comment-17759623
]
Hamed Hatami commented on CAMEL-19789:
--------------------------------------
CLOSED state happens when the connection is broken or discontinued right ? then
I assume the connection is open yet therefore in case you have multiple shards
you need to consume all shards not only the one which is specified in the
config ?! the way I have developed despite the fact , I didn't mention to that
existing issue but it was able to real from multiple shards in in DSL you don't
give any specific shard idÂ
> Kinesis2Consumer repeatedly reads first record in stream
> --------------------------------------------------------
>
> Key: CAMEL-19789
> URL: https://issues.apache.org/jira/browse/CAMEL-19789
> Project: Camel
> Issue Type: Bug
> Components: camel-aws2
> Affects Versions: 4.0.0
> Reporter: Karen Lease
> Assignee: Karen Lease
> Priority: Major
> Fix For: 4.0.1, 4.1.0
>
>
> A route using from:aws2-kinesis produces Exchanges which have identical
> content which correspond to the first record in the Kinesis stream.
> This is due to a change in the way the shardIterator is managed in PR
> https://github.com/apache/camel/pull/10733.
> The issue is not found by KinesisConsumerIT because it doesn't check that it
> receives 20 different records.
> The issue is visible in camel-examples/debezium.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
