Google Cloud Associate Data Practitioner — Question 27

Your organization sends IoT event data to a Pub/Sub topic. Subscriber applications read and perform transformations on the messages before storing them in the data warehouse. During particularly busy times when more data is being written to the topic, you notice that the subscriber applications are not acknowledging messages within the deadline. You need to modify your pipeline to handle these activity spikes and continue to process the messages. What should you do?

Answer options

• A. Retry messages until they are acknowledged.
• B. Implement flow control on the subscribers.
• C. Forward unacknowledged messages to a dead-letter topic.
• D. Seek back to the last acknowledged message.

Correct answer: B

Explanation

Implementing flow control on the subscribers helps manage the rate at which messages are processed, allowing the system to handle spikes in data more efficiently. The other options, such as retrying messages or sending them to a dead-letter topic, do not address the root cause of slow processing during high load periods, and seeking back to the last acknowledged message may not resolve the issue of processing delays.