Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagescala
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

...