
Ultimate access to all questions.
As a data engineer, you oversee managing a streaming data pipeline that collects and processes data from Google Cloud Pub/Sub in a production environment. Recently, there has been a need to enhance this pipeline with updated business logic. In addition to updating the business logic, it is crucial to ensure that the reconfigured pipeline can reprocess the Pub/Sub messages that were delivered over the past two days. What actions should you take to achieve this objective? (Choose two.)
A
Use the Pub/Sub subscription clear-retry-policy flag
B
Use Pub/Sub Snapshot capture two days before the deployment.
C
Create a new Pub/Sub subscription two days before the deployment.
D
Use the Pub/Sub subscription retain-acked-messages flag.
E
Use Pub/Sub Seek with a timestamp.