From 86d332428564bb02f0eb2a0024916c59465a1989 Mon Sep 17 00:00:00 2001 From: Christian Groschupp Date: Thu, 9 Jan 2020 17:20:00 +0100 Subject: [PATCH] return error in clusterCreate --- ccloud/provider.go | 2 +- ccloud/resource_kafka_cluster.go | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/ccloud/provider.go b/ccloud/provider.go index dc6c93c..b3c56e2 100644 --- a/ccloud/provider.go +++ b/ccloud/provider.go @@ -33,7 +33,7 @@ func Provider() terraform.ResourceProvider { } func providerConfigure(d *schema.ResourceData) (interface{}, error) { - log.Printf("[INFO] Initializing KafkaConnect client") + log.Printf("[INFO] Initializing ConfluentCloud client") username := d.Get("username").(string) password := d.Get("password").(string) c := confluentcloud.NewClient(username, password) diff --git a/ccloud/resource_kafka_cluster.go b/ccloud/resource_kafka_cluster.go index 058785d..8d15fbd 100644 --- a/ccloud/resource_kafka_cluster.go +++ b/ccloud/resource_kafka_cluster.go @@ -80,10 +80,12 @@ func clusterCreate(d *schema.ResourceData, meta interface{}) error { } cluster, err := c.CreateCluster(req) - if err == nil { - d.SetId(cluster.ID) + if err != nil { + return err } + d.SetId(cluster.ID) + return nil }