An analytics company specializes in processing automobile health-status data from taxis operated by a ride-hailing service using Kinesis Data Streams (KDS). The data streams are consumed by multiple applications. However, the engineering team has observed a lag in data delivery speed between the data stream producers and consumers.

As a Developer Associate, which of the following options would you suggest to improve the performance for this specific use-case?