public long retrieveOffset()

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

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

    public long retrieveOffset(String topicName, Reset reset) {
        try (KafkaConsumer<String, String> consumer = createConsumer(StringDeserializer.class, reset)) {
            TopicPartition topicPartition = new TopicPartition(topicName, PARTITION);
            Map<TopicPartition, Long> offsets = getOffsets(reset, consumer, topicPartition);
            return offsets.get(topicPartition);
        }
    }