@Override
            DescribeTopicPartitionsRequest.Builder createRequest(int timeoutMs) {
                DescribeTopicPartitionsRequestData request = new DescribeTopicPartitionsRequestData()
                    .setTopics(new ArrayList<>(topicsRequests.values()))
                    .setResponsePartitionLimit(options.partitionSizeLimitPerResponse());
                if (partiallyFinishedTopicDescription != null) {
                    // If the previous cursor points to partition 0, it will not be set here. Instead, the previous
                    // cursor topic will be the first topic in the request.
                    request.setCursor(new DescribeTopicPartitionsRequestData.Cursor()
                        .setTopicName(partiallyFinishedTopicDescription.name())
                        .setPartitionIndex(partiallyFinishedTopicDescription.partitions().size())
                    );
                }
                return new DescribeTopicPartitionsRequest.Builder(request);
            }
Fail futures in the given Map which were retried due to exceeding quota. We propagate
the initial error back to the caller if the request timed out.
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java