fix(pulsar): ensure auth data is updated during function/connector updates (#178)

* build(deps): upgrade pulsar-client-go to v0.18.0-candidate-1

* fix(pulsar): ensure auth data is updated during resource updates

* test(pulsar): update topic config test values

Author: freeznet

go.mod

@@ -3,7 +3,7 @@ module github.com/streamnative/terraform-provider-pulsar
 go 1.24.4
 
 require (
-	github.com/apache/pulsar-client-go v0.15.2-0.20250710023731-c587b5cefb04
+	github.com/apache/pulsar-client-go v0.18.0-candidate-1.0.20251217021558-9d65d0ecf43f
 	github.com/cenkalti/backoff/v4 v4.2.1
 	github.com/hashicorp/go-cty v1.4.1-0.20200414143053-d3edf31b6320
 	github.com/hashicorp/go-multierror v1.1.1

go.sum

@@ -18,6 +18,8 @@ github.com/agext/levenshtein v1.2.2 h1:0S/Yg6LYmFJ5stwQeRp6EeOcCbj7xiqQSdNelsXva
 github.com/agext/levenshtein v1.2.2/go.mod h1:JEDfjyjHDjOF/1e4FlBE/PkbqA9OfWu2ki2W0IB5558=
 github.com/apache/pulsar-client-go v0.15.2-0.20250710023731-c587b5cefb04 h1:3BoszOdT9uueXXsqzZiYgrlc7B1+R0lEjGlJADwl+KU=
 github.com/apache/pulsar-client-go v0.15.2-0.20250710023731-c587b5cefb04/go.mod h1:ow9PhLoGUY6ncrKOtjnWeJycFnTKOwrIV39j3kNV54M=
+github.com/apache/pulsar-client-go v0.18.0-candidate-1.0.20251217021558-9d65d0ecf43f h1:L2zBKmcYD/qyko07XLxVYg97kXVqN+SMI/ZySf0m7+A=
+github.com/apache/pulsar-client-go v0.18.0-candidate-1.0.20251217021558-9d65d0ecf43f/go.mod h1:GKmTD1u5YLuhUnoVTNGdhdGNAYhoglWNWgwLJZTljAw=
 github.com/apparentlymart/go-textseg/v12 v12.0.0/go.mod h1:S/4uRK2UtaQttw1GenVJEynmyUenKwP++x/+DdGV/Ec=
 github.com/apparentlymart/go-textseg/v15 v15.0.0 h1:uYvfpb3DyLSCGWnctWKGj857c6ew1u1fNQOlOtuGxQY=
 github.com/apparentlymart/go-textseg/v15 v15.0.0/go.mod h1:K8XmNZdhEBkdlyDdvbmmsvpAG721bKi0joRfFdHIWJ4=

pulsar/resource_pulsar_function.go

@@ -545,7 +545,9 @@ func resourcePulsarFunctionUpdate(ctx context.Context, d *schema.ResourceData, m
 		archive = *functionConfig.Go
 	}
 
-	updateOptions := utils.NewUpdateOptions()
+	updateOptions := &utils.UpdateOptions{
+		UpdateAuthData: true,
+	}
 	if isPackageURLSupported(archive) {
 		err = client.UpdateFunctionWithURL(functionConfig, archive, updateOptions)
 	} else {

pulsar/resource_pulsar_sink.go

@@ -606,7 +606,9 @@ func resourcePulsarSinkUpdate(ctx context.Context, d *schema.ResourceData, meta
 		return diag.FromErr(err)
 	}
 
-	updateOptions := utils.NewUpdateOptions()
+	updateOptions := &utils.UpdateOptions{
+		UpdateAuthData: true,
+	}
 	if isPackageURLSupported(sinkConfig.Archive) {
 		err = client.UpdateSinkWithURL(sinkConfig, sinkConfig.Archive, updateOptions)
 	} else {

pulsar/resource_pulsar_source.go

@@ -535,7 +535,9 @@ func resourcePulsarSourceUpdate(ctx context.Context, d *schema.ResourceData, met
 		return diag.FromErr(err)
 	}
 
-	updateOptions := utils.NewUpdateOptions()
+	updateOptions := &utils.UpdateOptions{
+		UpdateAuthData: true,
+	}
 	if isPackageURLSupported(sourceConfig.Archive) {
 		err = client.UpdateSourceWithURL(sourceConfig, sourceConfig.Archive, updateOptions)
 	} else {

pulsar/resource_pulsar_topic_test.go

@@ -253,9 +253,9 @@ func TestTopicWithTopicConfigUpdate(t *testing.T) {
 				Check: resource.ComposeTestCheckFunc(
 					testPulsarTopicExists(resourceName, t),
 					resource.TestCheckResourceAttr(resourceName, "topic_config.#", "1"),
-					resource.TestCheckResourceAttr(resourceName, "topic_config.0.max_consumers", "0"),
-					resource.TestCheckResourceAttr(resourceName, "topic_config.0.max_producers", "0"),
-					resource.TestCheckResourceAttr(resourceName, "topic_config.0.message_ttl_seconds", "0"),
+					resource.TestCheckResourceAttr(resourceName, "topic_config.0.max_consumers", "-1"),
+					resource.TestCheckResourceAttr(resourceName, "topic_config.0.max_producers", "-1"),
+					resource.TestCheckResourceAttr(resourceName, "topic_config.0.message_ttl_seconds", "-1"),
 				),
 			},
 			{