private void addPartitionsToRetry(Set<TopicPartition> partitionsToRetry) {
            remainingToSearch.putAll(partitionsToRetry.stream()
                    .collect(Collectors.toMap(tp -> tp, timestampsToSearch::get)));
        }
Build OffsetsForLeaderEpoch request to send to a specific broker for the partitions and
positions to fetch. This also adds the request to the list of unsentRequests.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java