A team requires an engine capable of stream processing of massive real-time data records with exactly-once semantics for a mission-critical application. Which Alibaba Cloud Big Data component best fits this requirement?