You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Rohit Deshpande (Jira)" <ji...@apache.org> on 2021/03/01 17:56:00 UTC

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

     [ 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)