Google Cloud Professional Data Engineer PDE — Topic 1 Question 228

Question

You have a streaming pipeline that ingests data from Pub/Sub in production. You need to update this streaming pipeline with improved business logic. You need to ensure that the updated pipeline reprocesses the previous two days of delivered Pub/Sub messages. What should you do? (Choose two.)

Accepted Answer

Correct answer: D. The correct answer is D. Option D: Use the Pub/Sub subscription retain-acked-messages flag. Pub/Sub is a serverless, global messaging service that decouples services and ingests high-volume event streams. This option meets the real-time / low-latency performance requirement.

Google Cloud Professional Data Engineer PDE — Question 228