Update pkg/admin/impl.go

freeznet · Copilot · web-flow · commit 88404e35de26 · 2025-07-01T09:55:14.000+08:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/pkg/admin/impl.go b/pkg/admin/impl.go
@@ -517,12 +517,9 @@ func (p *PulsarAdminClient) applyNamespacePolicies(completeNSName string, params
 		}
 	}
 
-	schemaStrategy := utils.AlwaysCompatible // default value
 	if params.SchemaCompatibilityStrategy != nil {
-		schemaStrategy = *params.SchemaCompatibilityStrategy
-	}
-	if schemaStrategy != utils.AlwaysCompatible {
-		err = p.adminClient.Namespaces().SetSchemaAutoUpdateCompatibilityStrategy(*naName, schemaStrategy)
+		schemaStrategy := *params.SchemaCompatibilityStrategy
+		err := p.adminClient.Namespaces().SetSchemaAutoUpdateCompatibilityStrategy(*naName, schemaStrategy)
 		if err != nil {
 			return err
 		}

Original file line number	Diff line number	Diff line change
`@@ -517,12 +517,9 @@ func (p *PulsarAdminClient) applyNamespacePolicies(completeNSName string, params`
`517`	`517`	`}`
`518`	`518`	`}`
`519`	`519`
`520`		`- schemaStrategy := utils.AlwaysCompatible // default value`
`521`	`520`	`if params.SchemaCompatibilityStrategy != nil {`
`522`		`- schemaStrategy = *params.SchemaCompatibilityStrategy`
`523`		`- }`
`524`		`- if schemaStrategy != utils.AlwaysCompatible {`
`525`		`- err = p.adminClient.Namespaces().SetSchemaAutoUpdateCompatibilityStrategy(*naName, schemaStrategy)`
	`521`	`+ schemaStrategy := *params.SchemaCompatibilityStrategy`
	`522`	`+ err := p.adminClient.Namespaces().SetSchemaAutoUpdateCompatibilityStrategy(*naName, schemaStrategy)`
`526`	`523`	`if err != nil {`
`527`	`524`	`return err`
`528`	`525`	`}`