A financial services company is building a real-time transaction processing platform. Multiple independent downstream applications must each consume the full stream of transaction events, and some teams need the ability to reprocess (replay) events from up to 7 days in the past for auditing and reconciliation. The platform must support high sustained throughput and be compatible with the team's existing open-source stream-processing tooling. Which service best meets these requirements?