private void createTopics()

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

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

  private void createTopics(Set<String> topicNames, AdminClient kafkaAdminClient) {
    var createTopicsResult = kafkaAdminClient.createTopics(getNewTopics(topicNames));
    createTopicsResult.values().forEach(this::handleTopicCreationResult);
  }