-
- String instance = ":topic." + topic.getFqtn();
- String topicPerm = dmaapService.getTopicPerm();
- removePermission(topicPerm, instance, "pub");
- removePermission(topicPerm, instance, "sub");
- removePermission(topicPerm, instance, "view");
-
- if (createTopicRoles && topic.getFqtn().startsWith(getTopicsNsRoot())) {
- removeNamespace(topic);
+ if (performCleanup()) {
+ String instance = ":topic." + topic.getFqtn();
+ String topicPerm = dmaapService.getTopicPerm();
+ removePermission(topicPerm, instance, "pub");
+ removePermission(topicPerm, instance, "sub");
+ removePermission(topicPerm, instance, "view");
+
+ if (createTopicRoles() && topic.getFqtn().startsWith(getTopicsNsRoot())) {
+ removeNamespace(topic);
+ }