private Map getOffsetsFromHandlerTask()

in src/main/java/com/epam/eco/commons/kafka/consumer/advanced/AdvancedConsumer.java [320:336]

• 16 lines of code
• 5 McCabe index (conditional complexity)

    private Map<TopicPartition, Long> getOffsetsFromHandlerTask(boolean waitForComplete) {
        if (handlerTask == null) {
            return Collections.emptyMap();
        }

        if (waitForComplete) {
            try {
                return handlerTaskFuture.get();
            } catch (InterruptedException ie) {
                throw new RuntimeException("Handler task interrupted", ie);
            } catch (ExecutionException ee) {
                throw new RuntimeException("Handler task failed", ee.getCause());
            }
        } else {
            return handlerTask.getCurrentOffsetsToCommit();
        }
    }