private Set getDlqTopics()

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

16 lines of code
2 McCabe index (conditional complexity)


  private Set<String> getDlqTopics() {
    if (!kafkaProperties.getTopicProperties().getCreation().isEnabledDlq()) {
      return Collections.emptySet();
    }
    var requestReplyDlq =
        kafkaProperties.getRequestReply().getTopics().values().stream()
            .map(handler -> handler.getRequest() + DLQ_TOPIC_SUFFIX)
            .collect(Collectors.toSet());
    var simpleTopicsDlq =
        kafkaProperties.getTopics().values().stream()
            .map(name -> name + DLQ_TOPIC_SUFFIX)
            .collect(Collectors.toSet());
    return Stream.of(requestReplyDlq, simpleTopicsDlq)
        .flatMap(Collection::stream)
        .collect(Collectors.toSet());
  }