You Operate an IoT Pipeline Built Around Apache Kafka That

question 164

Multiple Choice

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?

• A) Consume the stream of data in Cloud Dataflow using Kafka IO. Set a sliding time window of 1 hour every 5 minutes. Compute the average when the window closes, and send an alert if the average is less than 4000 messages.
• B) Consume the stream of data in Cloud Dataflow using Kafka IO. Set a fixed time window of 1 hour. Compute the average when the window closes, and send an alert if the average is less than 4000 messages.
• C) Use Kafka Connect to link your Kafka message queue to Cloud Pub/Sub. Use a Cloud Dataflow template to write your messages from Cloud Pub/Sub to Cloud Bigtable. Use Cloud Scheduler to run a script every hour that counts the number of rows created in Cloud Bigtable in the last hour. If that number falls below 4000, send an alert.
• D) Use Kafka Connect to link your Kafka message queue to Cloud Pub/Sub. Use a Cloud Dataflow template to write your messages from Cloud Pub/Sub to BigQuery. Use Cloud Scheduler to run a script every five minutes that counts the number of rows created in BigQuery in the last hour. If that number falls below 4000, send an alert.

---

Definitions:

Sequencer Chart

A graphical representation of steps or operations in sequential control processes, often used in programming automation processes.

I/O Devices

Devices connected to a control system, capable of providing input to or receiving output from the system.

Last-In, First-Out

A method of data storage or retrieval where the most recently stored information is the first to be retrieved.

FFL and FFU Instructions

FFL (FIFO Load) and FFU (FIFO Unload) are instructions used in programming PLCs for managing data in a First-In-First-Out (FIFO) manner.