AWS Certified Data Analytics – Specialty — Question 135

A media analytics company consumes a stream of social media posts. The posts are sent to an Amazon Kinesis data stream partitioned on user_id. An AWS
Lambda function retrieves the records and validates the content before loading the posts into an Amazon OpenSearch Service (Amazon Elasticsearch Service) cluster. The validation process needs to receive the posts for a given user in the order they were received by the Kinesis data stream.
During peak hours, the social media posts take more than an hour to appear in the Amazon OpenSearch Service (Amazon ES) cluster. A data analytics specialist must implement a solution that reduces this latency with the least possible operational overhead.
Which solution meets these requirements?

Answer options

• A. Migrate the validation process from Lambda to AWS Glue.
• B. Migrate the Lambda consumers from standard data stream iterators to an HTTP/2 stream consumer.
• C. Increase the number of shards in the Kinesis data stream.
• D. Send the posts stream to Amazon Managed Streaming for Apache Kafka instead of the Kinesis data stream.

Correct answer: C

Explanation

Increasing the number of shards in the Kinesis data stream allows for higher throughput, enabling the Lambda function to process more records concurrently, which can reduce latency. The other options either do not address the specific requirement for order preservation or do not effectively solve the latency issue with minimal operational overhead.