private long fixOffsetBoundaries()

in src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/ConsumerGroupOffsetThresholdProvider.java [143:156]

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

    private long fixOffsetBoundaries(OffsetAndMetadata meta, OffsetRange range) {
        if (meta.offset() < range.getSmallest()) {
            return -1;
        }

        long largestConsumerOffset = range.isLargestInclusive() ?
                        range.getLargest() + 1 :
                        range.getLargest();
        if (meta.offset() > largestConsumerOffset) {
            return largestConsumerOffset;
        }

        return meta.offset();
    }