delete BookieAffinityGroup policy when not present

streamnative · Nov 22, 2024 · 9318064 · 9318064
1 parent fd9405f
commit 9318064
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/admin/impl.go b/pkg/admin/impl.go
@@ -464,6 +464,11 @@ func (p *PulsarAdminClient) applyNamespacePolicies(completeNSName string, params
 		if err != nil {
 			return err
 		}
+	} else {
+		err = p.adminClient.Namespaces().DeleteBookieAffinityGroup(completeNSName)
+		if err != nil {
+			return err
+		}
 	}
 
 	return nil