A Media Analytics Company Consumes a Stream of Social Media

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 Service (Amazon ES) 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 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?

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.