You manage a data pipeline that streams user activity logs from Pub/Sub to BigQuery. Analysts report that data ingestion is delayed, and new records are arriving much later than expected. The messages are still being successfully published to Pub/Sub. You need to diagnose and resolve the issue. What should you do?