diff --git a/CHANGELOG.md b/CHANGELOG.md index 18209e0b4..503aad00a 100644 --- 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 index cdffbd20d..812273b0e 100644 --- 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