0

ドキュメントによると、Dynamodb ストリームと Kinesis データ ストリームの低レベル API は似ていますが、100% 同一ではありません。

Dynamodb ストリームの GetShardIteratorが少し異なることに気付きました。つまり、シャード イテレータ タイプとして AT_TIMESTAMP をサポートしていません。

したがって、アダプターの実装によって KCL コンシューマーの機能が制限され、AT_TIMESTAMP の開始位置が許可されなくなると思います。

私の推論は正しいですか？私はまだそれを実装していません。これがブロックポイントであると思われる場合は、別の解決策を探すことを好みます。

4

1 に答える 1

0

Dynamodb ストリーム kinesis アダプターを使用する場合、Kinesis Client Library コンシューマーは開始位置として AT_TIMESTAMP をサポートしません。

https://github.com/awslabs/dynamodb-streams-kinesis-adapter/blob/50750146b1ccc1d87793522780ca21b4e376b2e1/src/main/java/com/amazonaws/services/dynamodbv2/streamsadapter/model/GetShardIteratorRequestAdapter.java#L142

于 2020-08-04T14:36:26.307 に答える