public Map getMessageQueueOffsets()

in src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/offset/OffsetsSelectorByStrategy.java [42:54]

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

    public Map<MessageQueue, Long> getMessageQueueOffsets(
            Collection<MessageQueue> messageQueues, MessageQueueOffsetsRetriever offsetsRetriever) {

        switch (consumeFromWhere) {
            case CONSUME_FROM_FIRST_OFFSET:
                return offsetsRetriever.minOffsets(messageQueues);
            case CONSUME_FROM_MAX_OFFSET:
                return offsetsRetriever.maxOffsets(messageQueues);
            case CONSUME_FROM_LAST_OFFSET:
            default:
                return offsetsRetriever.committedOffsets(messageQueues);
        }
    }