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;
}