public void startConsumerThread() {
        try {
            // Start a thread to continuously consume records from topic partitions.
            consumerTaskThread.start();
            log.info("RLMM Consumer task thread is started");
        } catch (Exception e) {
            throw new KafkaException("Error encountered while initializing and scheduling ConsumerTask thread", e);
        }
    }
This class manages the consumer thread viz {@link ConsumerTask} that polls messages from the assigned metadata topic partitions.
It also provides a way to wait until the given record is received by the consumer before it is timed out with an interval of
{@link TopicBasedRemoteLogMetadataManagerConfig#consumeWaitMs()}.
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerManager.java