AWS Certified Data Engineer Associate (DEA-C01) - 340 Questions

1. A data engineer needs to ingest clickstream events from a website into AWS for real-time processing. The application generates approximately 5,000 records per second, and each record is 2 KB in size. The engineer needs to determine the minimum number of shards required for an Amazon Kinesis Data Stream. How many shards are needed?

2. A company is using Amazon Kinesis Data Streams to ingest sensor data. The default data retention period is not long enough for their recovery requirements. A data engineer needs to retain records in the stream for 10 days to allow replay in case of downstream failures. What is the correct action?

3. A data engineer is designing a Kinesis Data Streams producer application. The stream has 4 shards. Records from the same IoT device must always be processed in order. Which mechanism ensures that all records from the same device are routed to the same shard?

4. A company is streaming financial transaction data through Amazon Kinesis Data Streams. A downstream Lambda function using the standard GetRecords API is experiencing high latency because it shares read throughput with three other consumer applications. What is the most effective solution to eliminate this read throughput contention?

5. A company uses Amazon Kinesis Data Firehose to deliver log data to Amazon S3. The data team wants to convert the incoming JSON records to Apache Parquet format before storage to reduce query costs in Amazon Athena. Which feature of Kinesis Data Firehose should they enable?