hardMultiple ChoiceObjective-mapped
Google ACE Practice Question: Your Dataflow streaming pipeline is consuming…
Your Dataflow streaming pipeline is consuming messages from Pub/Sub but the pipeline's throughput has dropped significantly. Cloud Monitoring shows the `pubsub/subscription/oldest_unacked_message_age` metric is growing. The pipeline has enough workers. What is the most likely bottleneck, and how should you address it?
⚠ Common exam trap
Google Cloud often tests the misconception that adding more workers or increasing timeouts always solves throughput issues, but the correct approach is to diagnose the specific bottleneck stage using Dataflow's built-in metrics.
Answer choices
Why each option matters
Answer the question above first, then reveal the full breakdown to understand why each option is right or wrong.
Correct answer & explanation
✓
Inspect Dataflow job graph metrics to identify the slow stage, then optimize that stage's logic or address data skew.
The growing `oldest_unacked_message_age` metric indicates that messages are not being processed and acknowledged quickly enough, even though the pipeline has enough workers. This points to a bottleneck within a specific stage of the Dataflow pipeline, such as a transformation or grouping operation that is slow or suffering from data skew. Option B is correct because inspecting the job graph metrics (e.g., wall time, backlog, and throughput per stage) allows you to identify the slow stage and then optimize its logic or address data skew, which directly resolves the processing delay.
Answer analysis
Option-by-option breakdown
For each option: why learners choose it and why it is or isn't the right answer here.
- ✗
Increase the number of Dataflow workers to process messages faster.
Why it's wrong here
The scenario explicitly states there are already enough workers, so horizontal scaling only adds idle vCPUs and memory. A throughput bottleneck lives inside a particular stage (e.g., an inefficient CoGroupByKey, a hot key causing skew, or a blocking call to an external service); more workers cannot accelerate that stage and may even increase network/shuffle contention, making the pipeline slower or more costly.
- ✓
Inspect Dataflow job graph metrics to identify the slow stage, then optimize that stage's logic or address data skew.
Why this is correct
The Dataflow monitoring UI's job graph exposes per-stage counted metrics (element counts, throughput, and execution time). Pinpointing the stage with the highest processing lag or a hot key reveals whether the slowness comes from a transform's computational cost, external API latency, or data skew, enabling a targeted fix like partitioning by key or batching I/O calls instead of a blind capacity change.
- ✗
Increase the Pub/Sub subscription's ack deadline to 600 seconds.
Why it's wrong here
Raising the Pub/Sub subscription ack deadline merely lengthens the window a worker has to acknowledge a message before it is redelivered; it does not increase the rate at which messages are processed or reduce the publication backlog. The pipeline still consumes messages at the same slow pace, and redeliveries may even increase if the worker stalls, so this just masks the symptom while resource utilization stays unchanged.
- ✗
Switch from Dataflow to Pub/Sub Lite for lower cost and higher throughput.
Why it's wrong here
Pub/Sub Lite is a fully managed pub/sub message queue, not a compute engine; it cannot execute Dataflow transforms, windowing, or stateful processing. Replacing Dataflow with Pub/Sub Lite would simply move the backlog to a different queue while dropping all pipeline logic, and the claimed cost/latency benefits do nothing to fix the slow processing stage identified in the job graph.
Visual reference
Go deeper
Related to this question
Learn chapter
Google Cloud Platform Overview
Key term
Alerting policy
An alerting policy is a set of rules that defines when to send notifications about a system condition that needs attention.
Key term
Cloud Monitoring
Cloud monitoring is the process of observing, measuring, and managing an organization's cloud infrastructure and applications to ensure performance, availability, and security.
About these practice questions
This ACE question is part of Courseiva's 769-question bank — original exam-style content with full explanations and wrong-answer analysis, never real exam questions or exam dumps. Learn why practice questions differ from exam dumps →
JA
Written by Johnson Ajibi, MSc IT Security
Senior Network & Security Engineer · founder of Courseiva
This ACE practice question is part of Courseiva's free Google Cloud certification practice question bank. Courseiva provides original exam-style practice questions with explanations, topic-based practice, mock exams, readiness tracking, and study analytics to help learners prepare for the ACE exam.