public void waitTillConsumptionCatchesUp(RecordMetadata recordMetadata) throws TimeoutException {
        waitTillConsumptionCatchesUp(recordMetadata, rlmmConfig.consumeWaitMs());
    }
Waits if necessary for the consumption to reach the {@code offset} of the given record
at a certain {@code partition} of the metadata topic.

@param recordMetadata record metadata to be checked for consumption.
@throws TimeoutException if this method execution did not complete with in the wait time configured with
                         property {@code TopicBasedRemoteLogMetadataManagerConfig#REMOTE_LOG_METADATA_CONSUME_WAIT_MS_PROP}.
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerManager.java