Scenario: You are designing a data processing pipeline that must scale automatically as the load increases. The solution must process each message at least once and ensure messages are ordered within 1-hour windows. Question: How should you design the solution to meet these requirements?