feat(kafkatopic): creation simplification (#1357)

internal/sdkprovider/service/kafkatopic/kafka_topic.go

@@ -289,19 +289,13 @@ func resourceKafkaTopicCreate(ctx context.Context, d *schema.ResourceData, m int
 		Tags:        getTags(d),
 	}
 
-	w := &kafkaTopicCreateWaiter{
-		Context:       ctx,
-		Client:        m.(*aiven.Client),
-		Project:       project,
-		ServiceName:   serviceName,
-		CreateRequest: createRequest,
-	}
-
-	timeout := d.Timeout(schema.TimeoutCreate)
-
-	// nolint:staticcheck // TODO: Migrate to helper/retry package to avoid deprecated WaitForStateContext.
-	_, err = w.Conf(timeout).WaitForStateContext(ctx)
-	if err != nil {
+	err = m.(*aiven.Client).KafkaTopics.Create(
+		ctx,
+		project,
+		serviceName,
+		createRequest,
+	)
+	if err != nil && !aiven.IsAlreadyExists(err) {
 		return diag.FromErr(err)
 	}
 

internal/sdkprovider/service/kafkatopic/kafka_topic_cache.go

@@ -172,6 +172,10 @@ func (t *kafkaTopicCache) GetV1List(projectName, serviceName string) []string {
 }
 
 // DeleteTopicFromCache Invalidates cache for the topic
+// This function only exists to pass acceptance tests. Cache invalidation
+// happens automatically in Terraform when used in the real-life world between
+// each subsequent operation. However, during the acceptance test execution,
+// we need to mimic the cache invalidation mechanism by calling this function.
 func DeleteTopicFromCache(projectName, serviceName, topicName string) {
 	t := getTopicCache()
 	t.Lock()