This is a dedicated watch page for a single video.
Scenario: In your car factory, machine measurements are being sent as messages into a Pub/Sub topic in your Google Cloud project. A Dataflow streaming job, written with the Apache Beam SDK, processes these messages, acknowledges them, applies custom business logic in a DoFn instance, and writes the result to BigQuery. You want to ensure that if the business logic fails for any message, that message is sent to a Pub/Sub topic for monitoring and alerting purposes. Question: How can you ensure that messages failing the business logic are redirected to a monitoring Pub/Sub topic?