[KAFKA-6857] LeaderEpochFileCache.endOffsetFor() should check for UNDEFINED_EPOCH explicitly

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.11.0.0
• Fix Version/s: 0.11.0.3, 1.0.2, 1.1.1, 2.0.0
• Component/s: core
• Assignee: Anna Povzner
• Reporter: Jun Rao
• Created: 03/May/18 23:54
• Updated: 14/May/18 21:19
• Resolved: 04/May/18 15:33

Description

In LeaderEpochFileCache.endOffsetFor() , we have the following code.

 

 

if (requestedEpoch == latestEpoch) {
 leo().messageOffset

 

In the case when the requestedEpoch is UNDEFINED_EPOCH and latestEpoch is also UNDEFINED_EPOCH, we return leo. This will cause the follower to truncate to a wrong offset. If requestedEpoch is UNDEFINED_EPOCH, we need to request UNDEFINED_EPOCH_OFFSET.

Issue Links

• links to: GitHub Pull Request #4967