Jose Armando Garcia Sancio created KAFKA-12253: --------------------------------------------------
Summary: Add tests that cover all of all of the cases for ReplicatedLog::validateOffsetAndEpoch Key: KAFKA-12253 URL: https://issues.apache.org/jira/browse/KAFKA-12253 Project: Kafka Issue Type: Sub-task Components: replication Reporter: Jose Armando Garcia Sancio Add tests for the cases that ReplicatedLog::validateOffsetAndEpoch needs to cover. This include: # epoch > last known epoch => return diverging(log.endOffset, log.lastFetchedEpoch) # epoch < oldest snapshot epoch => return snapshot(latestSnapshotId) # epoch == oldest snapshot epoch: ## offset < oldest snapshot offset => return snapshot(latestSnapshotId) ## offset == oldest snapshot offset => return valid # Now look up end offset for epoch: ## epoch unknown => return diverging(endOffset/epoch) ## found epoch; end offset < offset => return diverging(endOffset/epoch) ## valid -- This message was sent by Atlassian Jira (v8.3.4#803005)