private Map getOffsets()

in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [174:180]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    private Map<TopicPartition, Long> getOffsets(Reset reset, KafkaConsumer<String, String> consumer,
            TopicPartition topicPartition) {
        Collection<TopicPartition> topicPartitions = singleton(topicPartition);
        return (reset == Reset.earliest) //
                ? consumer.beginningOffsets(topicPartitions)
                : consumer.endOffsets(topicPartitions);
    }