protected boolean areAllOffsetsReachedEndOfRange()

in src/main/java/com/epam/eco/commons/kafka/helpers/TopicRecordFetcher.java [513:527]

• 15 lines of code
• 4 McCabe index (conditional complexity)

    protected boolean areAllOffsetsReachedEndOfRange(
            Map<TopicPartition, Long> offsets,
            Map<TopicPartition, OffsetRange> offsetRanges) {
        if(offsets.isEmpty()) {
            return false;
        }
        for (Map.Entry<TopicPartition, Long> entry : offsets.entrySet()) {
            Long offset = entry.getValue();
            OffsetRange range = offsetRanges.get(entry.getKey());
            if (offset < range.getLargest()) {
                return false;
            }
        }
        return true;
    }