private Set getRequiredTopics()

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

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

  private Set<String> getRequiredTopics() {
    var requestReplyTopics =
        kafkaProperties.getRequestReply().getTopics().values().stream()
            .flatMap(handler -> Stream.of(handler.getRequest(), handler.getReply()))
            .collect(Collectors.toSet());
    var simpleTopics = kafkaProperties.getTopics().values();
    return Stream.of(requestReplyTopics, simpleTopics, getDlqTopics())
        .flatMap(Collection::stream)
        .collect(Collectors.toSet());
  }