diff --git a/src/main/java/com/michelin/ns4kafka/services/TopicService.java b/src/main/java/com/michelin/ns4kafka/services/TopicService.java index 1dcb9343..fee0d95a 100644 --- a/src/main/java/com/michelin/ns4kafka/services/TopicService.java +++ b/src/main/java/com/michelin/ns4kafka/services/TopicService.java @@ -358,12 +358,11 @@ public List validateTags(Namespace namespace, Topic topic) { .filter(tagName -> tagNames != null && !tagNames.contains(tagName)) .toList(); - if(topicCluster.isPresent() && - Boolean.parseBoolean( + if (topicCluster.isPresent() + && Boolean.parseBoolean( topicCluster.get().getConfig().getProperty( DYNAMIC_TAGS_CREATION, "true"))) { - List tagsToCreate = unavailableTagNames .stream() .map(TagInfo::new)