SAA-C03 Q705 · Streaming

Question

A company processes streaming data by using Amazon Kinesis Data Streams and an AWS Lambda function. The streaming data comes from devices that are connected to the internet. The company is experiencing scaling problems and needs to implement shard-level control and custom checkpointing. Which solution will meet these requirements with the LEAST latency?

Accepted Answer

The question has two critical requirements: (1) **shard-level control** and (2) **custom checkpointing**, plus the constraint of **least latency**.

**Why Kinesis Client Library (KCL) is the answer:**
- The **Kinesis Client Library (KCL)** is specifically designed to give developers fine-grained control over shard processing. It provides shard-level metrics, custom lease management, and the ability to implement **custom checkpointing** (deciding exactly when and which sequence numbers to checkpoint).
- Lambda's built-in Kinesis integration uses Event Source Mapping, which handles checkpointing automatically — you **cannot** customize it. Lambda checkpoints after successful batch processing, with no ability to checkpoint at arbitrary points within a batch.
- Lambda's Kinesis integration als

📖 Explanation

✅ Correct Answer

❌ Wrong Answers

📘 Key Concepts

🏗️ Architecture

⚙️ Operations

💰 Cost

🎯 Exam Tips