You are managing a single on-premises Kafka cluster located in a data center in the us-east region. This cluster handles the ingestion of messages from IoT devices worldwide. Due to poor internet connectivity in many parts of the world, messages often accumulate at the edge and are then sent in large batches, causing spikes in load on your Kafka cluster. This situation is becoming challenging to manage and increasingly costly. What is the Google-recommended cloud-native architecture for addressing this scenario?