[jira] [Created] (KAFKA-9686) MockConsumer#endOffsets should be idempotent

["Chia-Ping Tsai (Jira)" <ji...@apache.org>]

Chia-Ping Tsai created KAFKA-9686:
-------------------------------------

             Summary: MockConsumer#endOffsets should be idempotent
                 Key: KAFKA-9686
                 URL: https://issues.apache.org/jira/browse/KAFKA-9686
             Project: Kafka
          Issue Type: Bug
            Reporter: Chia-Ping Tsai
            Assignee: Chia-Ping Tsai


```scala
    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




--
This message was sent by Atlassian Jira
(v8.3.4#803005)