You are enhancing the business logic of a streaming pipeline that ingests data from Pub/Sub in production. To ensure the updated pipeline can reprocess Pub/Sub messages from the last two days, which two actions should you take? | Google Professional Data Engineer Quiz - LeetQuiz