diff --git a/internal/provider/resource_kafkaconnect_connector.go b/internal/provider/resource_kafkaconnect_connector.go index fdce51a..fc25f20 100644 --- a/internal/provider/resource_kafkaconnect_connector.go +++ b/internal/provider/resource_kafkaconnect_connector.go @@ -198,21 +198,23 @@ func checkIfConnectorExists( meta interface{}) (bool, error) { client := meta.(*connect.Client) + var attempts = 60 + var delay = 5 * time.Second var exists bool retryError := try.Do(func(attempt int) (bool, error) { _, _, err := client.GetConnectorStatus(data.Id()) if err != nil { if apiError, ok := err.(connect.APIError); ok { if apiError.Code == 404 { - if attempt < 30 { - time.Sleep(1 * time.Second) + if attempt < attempts { + time.Sleep(delay) return true, nil } return false, nil } } - if attempt < 30 { - time.Sleep(1 * time.Second) + if attempt < attempts { + time.Sleep(delay) return true, err } return false, err