Your Dataverse environment generates thousands of account update events per minute that must be streamed to a downstream analytics platform capable of ingesting large volumes of data with consumer groups for parallel processing. You use the Plug-in Registration Tool to register a service endpoint. Which endpoint contract type should you select to best match this high-throughput streaming requirement?