public void createKafkaTopics()

in src/main/java/com/epam/digital/data/platform/starter/kafka/service/StartupKafkaTopicsCreator.java [64:69]

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

  public void createKafkaTopics() {
    try (var kafkaAdminClient = adminClientFactory.get()) {
      var missingTopicNames = getMissingTopicNames(kafkaAdminClient);
      createTopics(missingTopicNames, kafkaAdminClient);
    }
  }