private Collection getNewTopics()

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

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

  private Collection<NewTopic> getNewTopics(Set<String> requiredTopics) {
    return requiredTopics.stream()
        .map(topicName -> new NewTopic(topicName,
            kafkaProperties.getTopicProperties().getNumPartitions(),
            kafkaProperties.getTopicProperties().getReplicationFactor()))
        .map(topic -> topic.configs(getRetentionPolicy(topic.name())))
        .collect(Collectors.toSet());
  }