DEA-C01 Practice Test 1

A ride-hailing platform publishes trip telemetry to an Amazon Kinesis Data Streams stream running in provisioned mode with 20 shards. Producers set the partition key to the city_id of the trip. Stream-level IncomingBytes shows the stream is running at roughly 25 percent of its provisioned capacity, yet producers log a steady stream of ProvisionedThroughputExceededException errors, and the WriteProvisionedThroughputExceeded metric is non-zero for only two of the 20 shards. The downstream consumer aggregates trips globally and does not depend on per-city ordering.

What should the data engineer do to eliminate the write throttling at the lowest cost?