This is a dedicated watch page for a single video.
Your IoT pipeline, constructed with Apache Kafka, typically processes around 5000 messages per second. You intend to utilize Google Cloud Platform to generate an alert when the moving average over 1 hour drops below 4000 messages per second. What approach should you take?