THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
def readFromLocaLog(): Seq[(TopicPartition, LogReadResult)] = { catch { case e@ (_: OffsetOutOfRangeException) => RemoteLogManager.read(fetchMaxBytes: Int, hardMaxBytesLimit: Boolean, readPartitionInfotp: Seq[(TopicPartition, PartitionData)], fetchInfo: PartitionData quota: ReplicaQuota) } |
Proposed Changes
...