You are tasked with designing an application to store and analyze social media postings in Google BigQuery at a rate of 10,000 messages per minute, aiming for near real-time processing. Initially, you plan to use streaming inserts for each individual posting. Following the streaming inserts, your application performs data aggregations immediately. However, you encounter an issue where the queries executed immediately after the streaming inserts lack strong consistency, leading to reports that might miss in-flight data. How can you modify your application design to address this issue?