private Set getRequiredTopics()

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


  private Set<String> getRequiredTopics(Map<String, Handler> rootsOfTopicNames) {
    Set<String> requiredTopics = new HashSet<>();
    for (Entry<String, Handler> e : rootsOfTopicNames.entrySet()) {
      requiredTopics.add(e.getValue().getRequest());
      requiredTopics.add(e.getValue().getRequest() + ".DLT");
      requiredTopics.add(e.getValue().getReplay());
    }
    return requiredTopics;
  }