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 Elasticsearch cluster. The validation process needs to receive the posts for a given user in the order they were received. A data analyst has noticed that, during peak hours, the social media platform posts take more than an hour to appear in the Elasticsearch cluster. What should the data analyst do reduce this latency?
A) Migrate the validation process to Amazon Kinesis Data Firehose.
B) Migrate the Lambda consumers from standard data stream iterators to an HTTP/2 stream consumer.
C) Increase the number of shards in the stream.
D) Configure multiple Lambda functions to process the stream.

Question

Quizplus · Accepted Answer

Increasing the number of shards in the stream can help reduce latency by allowing more parallel processing of the data, which can help handle peak loads more efficiently.

A Media Analytics Company Consumes a Stream of Social Media