A manufacturing company operates thousands of factory-floor sensors that currently publish telemetry to a self-managed Apache Kafka cluster on-premises. The company is moving to Azure and wants a fully managed PaaS ingestion service that its existing Kafka-based producer applications can connect to with minimal code changes. The solution must handle millions of events per second, support replaying a configurable retention window of raw events, and enable multiple independent downstream consumer groups to read the same stream. Which Azure service should you recommend?