THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
class RemoteLogManager extends Configurable { val RemoteStorageManager // configure def configure(Map<String, ?> configs) // Copies LogSegments yet to be copied to remote storage for the given set of TopicPartitions. It updates RemoteLogSegmentIndex once a LogSegment in a TopicPartition is copied to Remote Storage. def addPartitions(topicPartitions: Set[TopicPartition]): boolean // Stops copy Deletes LogSegments based on remote.log.retention.period or remote.log.retention.bytes configurationof LogSegment if TopicPartition ownership is moved from a broker. def removePartitions(topicPartitions: Set[TopicPartition]): boolean // Marks partitions as copied def markPartitionsAsCopied(topicPartitions: Set[TopicPartition]) // Read topic partition data from remote def read(fetchMaxByes: Int, hardMaxBytesLimit:Boolean, readPartitionInfo: Seq[(TopicPartition, PartitionData)]): LogReadResult // Stops all the threads and closes the instance. def shutdown(): Unit } |
...