diff --git a/pkg/admin/impl.go b/pkg/admin/impl.go index fceeb5c..1714804 100644 --- 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