You’re managing a real-time processing pipeline gcp video

Full Certification Question

You’re managing a real-time processing pipeline for AutoLine Manufacturing, where machine telemetry data is published into a Pub/Sub topic in your Google Cloud project. A Dataflow streaming job, written using the Apache Beam SDK, reads these messages, acknowledges them, processes them using a custom DoFn , and writes the results to BigQuery. You want to make sure that if a message fails during business logic execution, it is redirected to a separate Pub/Sub topic for monitoring and alerting purposes. What should you do?