protected boolean areAllOffsetsReachedEndOfRange()

in src/main/java/com/epam/eco/commons/kafka/helpers/BiDirectionalTopicRecordFetcher.java [297:310]

• 14 lines of code
• 5 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 (range.getSmallest() > range.getLargest() || offset > range.getSmallest()) {
                return false;
            }
        }
        return true;
    }