fix(kafka_topic): insufficient brokers error (#1501)

aiven · Jan 2, 2024 · f8557ab · f8557ab
1 parent 696836e
commit f8557ab
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -11,6 +11,8 @@ nav_order: 1
 
 ## [MAJOR.MINOR.PATCH] - YYYY-MM-DD
 
+- Fix insufficient brokers error when create kafka topic
+
 ## [4.11.0] - 2024-01-02
 
 - Add support for `aiven_organization_group_project`. Please note that this resource is in the beta stage, and to use it, you would need to set the environment variable PROVIDER_AIVEN_ENABLE_BETA to a non-zero value.

diff --git a/internal/sdkprovider/kafkatopicrepository/create.go b/internal/sdkprovider/kafkatopicrepository/create.go
@@ -44,7 +44,7 @@ func (rep *repository) Create(ctx context.Context, project, service string, req
 
 		// We must retry this one
 		if reInsufficientBrokers.MatchString(err.Error()) {
-			return nil
+			return retry.RetryableError(err)
 		}
 
 		// Other errors are non-retryable