mirror of https://github.com/apache/kafka.git
UnifiedLog relied on the remoteStorageSystemEnable to identify if the broker is enabling remote storage, but we never pass this value from the config into UnifiedLog. So it'll always be false. In this PR, I did: - pass remoteStorageSystemEnable to UnifiedLog - remove remoteLogManager from the class member of UnifiedLog since only UnifiedLog#fetchOffsetByTimestamp needs remoteLogManager, and this can be passed when called from ReplicaManager. Reviewers: Satish Duggana <satishd@apache.org>, Kamal Chandraprakash <kamal.chandraprakash@gmail.com> |
||
|---|---|---|
| .. | ||
| api/src | ||
| src | ||