[KAFKA-12253] Add tests that cover all of all of the cases for ReplicatedLog::validateOffsetAndEpoch

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: replication
• Assignee: Rohit Deshpande
• Reporter: Jose Armando Garcia Sancio
• Created: 29/Jan/21 19:54
• Updated: 19/Mar/21 17:10
• Resolved: 19/Mar/21 17:10

Description

Add tests for the cases that ReplicatedLog::validateOffsetAndEpoch needs to cover. This include:

 

1. epoch > last known epoch =>  return diverging(log.endOffset, log.lastFetchedEpoch)
2. epoch < oldest snapshot epoch => return snapshot(latestSnapshotId)
3. epoch == oldest snapshot epoch:
   1. offset < oldest snapshot offset => return snapshot(latestSnapshotId)
   2. offset == oldest snapshot offset => return valid
4. Now look up end offset for epoch:
   1. epoch unknown, less than the last known epoch and greater oldest snapshot epoch => return diverging(endOffset/epoch)
   2. found epoch in the log; end offset < offset => return diverging(endOffset/epoch)
   3. valid

Issue Links

• links to: GitHub Pull Request #10276
• links to: GitHub Pull Request #10276