private void checkTopicsAvailability()

in crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java [78:87]

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

    private void checkTopicsAvailability() {
        final Map<String, List<PartitionInfo>> topics = this.consumer.listTopics();

        if (mainTopic != null && !topics.containsKey(mainTopic)) {
            throw new RuntimeException("Main topic " + mainTopic + " is not available");
        }
        if (dlqTopic != null && !topics.containsKey(dlqTopic)) {
            throw new RuntimeException("DLQ topic " + dlqTopic + " is not available");
        }
    }