You operate an IoT pipeline built around Apache Kafka that normally receives around 5000 messages per second. You want to use Google Cloud Platform to create an alert as soon as the moving average ove

The correct answer is A. Consume the stream of data in Cloud Dataflow using Kafka IO.. Explanation/Reference: Dataflow can connect with Kafka and sliding window is used for taking averages.

Submitted by olafpl· Mar 30, 2026Building and operationalizing data processing systems

Question

You operate an IoT pipeline built around Apache Kafka that normally receives around 5000 messages per second. You want to use Google Cloud Platform to create an alert as soon as the moving average over 1 hour drops below 4000 messages per second. What should you do?

Options

AConsume the stream of data in Cloud Dataflow using Kafka IO.
BConsume the stream of data in Cloud Dataflow using Kafka IO.
CUse Kafka Connect to link your Kafka message queue to Cloud Pub/Sub.

How the community answered

(70 responses)

A
83% (58)
B
11% (8)
C
6% (4)

Explanation

Explanation/Reference: Dataflow can connect with Kafka and sliding window is used for taking averages.

Topics

#Cloud Dataflow#Apache Kafka#streaming analytics#moving average alert

Community Discussion

No community discussion yet for this question.

Full PROFESSIONAL-DATA-ENGINEER Practice