[KAFKA-9686] MockConsumer#endOffsets should be idempotent

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Assignee: Chia-Ping Tsai
• Reporter: Chia-Ping Tsai
• Created: 09/Mar/20 11:21
• Updated: 10/Mar/20 17:45
• Resolved: 10/Mar/20 16:40

Description

    private Long getEndOffset(List<Long> offsets) {
        if (offsets == null || offsets.isEmpty()) {
            return null;
        }
        return offsets.size() > 1 ? offsets.remove(0) : offsets.get(0);
    }

The above code has two issues.
1. It does not return the latest offset since the latest offset is at the end of offsets
1. It removes the element from offsets so MockConsumer#endOffsets gets non-idempotent

Issue Links

• fixes: KAFKA-9682 Flaky Test KafkaBasedLogTest#testSendAndReadToEnd
• is related to: KAFKA-9682 Flaky Test KafkaBasedLogTest#testSendAndReadToEnd
• links to: GitHub Pull Request #8255