public Optional<Long> readOffsetForPartition(int metadataPartition) {
        return consumerTask.readOffsetForMetadataPartition(metadataPartition);
    }
Waits if necessary for the consumption to reach the partition/offset of the given {@code RecordMetadata}

@param recordMetadata record metadata to be checked for consumption.
@param timeoutMs      wait timeout in milliseconds
@throws TimeoutException if this method execution did not complete with in the given {@code timeoutMs}.
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerManager.java