private boolean compareOffsetsGreaterOrEqual()

in src/main/java/com/epam/eco/commons/kafka/consumer/bootstrap/BootstrapConsumer.java [254:265]

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

    private boolean compareOffsetsGreaterOrEqual(
            Map<TopicPartition, Long> topicOffsets1,
            Map<TopicPartition, Long> topicOffsets2) {
        for (Map.Entry<TopicPartition, Long> entry : topicOffsets2.entrySet()) {
            Long offset1 = topicOffsets1.get(entry.getKey());
            Long offset2 = entry.getValue();
            if (offset1 == null || offset1 < offset2) {
                return false;
            }
        }
        return true;
    }