[
https://issues.apache.org/jira/browse/KAFKA-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohit Deshpande reassigned KAFKA-12253:
---------------------------------------
Assignee: Rohit Deshpande
> 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
> Assignee: Rohit Deshpande
> Priority: Major
>
> 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)
