Question

A media company runs a website that generates a high-volume clickstream. They need to ingest events in real time and have multiple independent consumer applications process the same records: one for a live analytics dashboard (sub-second latency), and another that aggregates data and writes hourly batches to a data lake. Ordering of events per user session must be preserved. Which ingestion solution best meets these requirements?

Accepted Answer

Ingest events into Amazon Kinesis Data Streams using the user session ID as the partition key, and attach both consumer applications to the stream.

Answer

Publish events to an Amazon SQS standard queue and have both applications poll the queue independently.

Answer

Use Amazon Kinesis Data Firehose to deliver events directly to Amazon S3, then have both applications read from the S3 bucket.

Answer

Write events to an Amazon DynamoDB table and enable DynamoDB Streams for each application to consume changes.