谁能分享一个使用KCL2 Java库使用dynamodb流的例子?



我一直在尝试使用KCL2库从DynamoDB流读取数据。然而,我遇到以下错误-

2022-06-09 11:51:50.717 ERROR [pay-orch-public-apis,,] 959982 --- [      Thread-13] s.amazon.kinesis.leases.ShardSyncTask    : Caught exception while sync'ing Kinesis shards and leases
software.amazon.awssdk.services.kinesis.model.ValidationException: 1 validation error detected: Value 'arn:aws:dynamodb:us-east-1:000000000000:table/merchant/stream/2022-06-08T19:08:14.229' at 'streamName' failed to satisfy constraint: Member must satisfy regular expression pattern: [a-zA-Z0-9_.-]+ (Service: Kinesis, Status Code: 400, Request ID: e6cfe0b7-7cd7-5469-bdd4-73098777541e, Extended Request ID: coIxVZGZPtfiq/NewMV3/vIPXBtEAL+S1kJD0fvOK52qw8ZDbSwvyzr/j+ZsJEUe1/NGr4zgppY411AgqCHIkYoTp5bE+RS6)

我想知道是否有使用KCL2库的DynamoDB流消费的任何示例,因为我可以找到相当多的KCL 1,但没有KCL2。

遇到同样的问题后,我发现KCL v2目前不支持dynamodb流:https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/streamsmain.html

最新更新