[pulsar-broker] avoid retrying deleting namespace when topic is already deleted/fenced
@@ -890,8 +890,11 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal
}).exceptionally(th -> {
log.error("[{}] Policies update failed {}, scheduled retry in {} seconds", topic, th.getMessage(),
POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS, th);
+ if (!(th.getCause() instanceof TopicFencedException)) {
+ // retriable exception
brokerService.executor().schedule(this::checkReplicationAndRetryOnFailure,
POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS, TimeUnit.SECONDS);
+ }
result.completeExceptionally(th);
return null;
});
