You are managing a system that processes messages from IoT devices worldwide. Currently, a single on-premises Kafka cluster in the us-east region handles all messages, but managing sporadic spikes in message volume has become challenging and costly. What Google Cloud architecture would you recommend for this scenario?