You are building a data processing pipeline for a retail tech firm, NexLogix Corp. The solution must automatically scale with fluctuating workloads. Additionally, all messages must be processed at least once , and message order must be preserved within 1-hour time windows . How should you architect this pipeline using cloud-native services?