This is a dedicated watch page for a single video.
You have a web server that publishes click event messages to a Pub/Sub topic . Each message includes an event Timestamp , representing when the user clicked. These messages are consumed by a Google Cloud Dataflow streaming job , which applies transformations and outputs them to another Pub/Sub topic for the advertising department . The advertising team requires that each message is received within 30 seconds of the original click time. However, they report that messages are arriving too late . Upon investigation: Your Dataflow job's system lag is 5 seconds . The overall data freshness is about 40 seconds . The difference between event Timestamp and Pub/Sub publish time is less than 1 second . Given this information, what is the likely cause of the delay, and what should you do?