RemoteLogManager¶

Creating Instance¶

RemoteLogManager takes the following to be created:

• RemoteLogManagerConfig
• Broker ID
• Log Directory
• Cluster ID
• Time
• Fetch Log Function (Function<TopicPartition, Optional<UnifiedLog>>)
• updateRemoteLogStartOffset (BiConsumer<TopicPartition, Long>)
• BrokerTopicStats

RemoteLogManager is created when:

• BrokerServer is requested to create a RemoteLogManager
• KafkaServer is requested to create a RemoteLogManager