Поддерживает ли клиент клиентской библиотеки Kinesis AT_TIMESTAMP в качестве начальной позиции при использовании адаптера Kinesis для потоков Dynamodb

Question

Согласно do c Потоки Dynamodb и низкоуровневые API потоков данных Kinesis похожи, но не идентичны на 100%.

Я заметил, что потоки Dynamodb GetShardIterator немного отличается, т.е. он не поддерживает AT_TIMESTAMP в качестве типа итератора сегментов.

Итак, я предполагаю, что реализация адаптера ограничит функциональные возможности потребителя KCL и не поддерживает 'Не допускается AT_TIMESTAMP начальная позиция.

Верны ли мои рассуждения? Я еще не реализовал это. Я предпочитаю искать другое решение, если это кажется блокирующей точкой.

Answer 1

Клиент клиентской библиотеки Kinesis не поддерживает AT_TIMESTAMP в качестве начальной позиции при использовании адаптера Kinesis для потоков Dynamodb:

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