You are a data engineer at an IT company. The company has multiple enterprise customers that use the company's mobile app to capture and send data to Amazon Kinesis Data Streams. The customers have been getting a ProvisionedThroughputExceededException exception. Upon analysis, you notice that messages are being sent one by one at a high rate. Which of the following options will help with the exception while keeping costs at a minimum?