ksql client. check response status code

serhiimakogon · Dec 27, 2022 · 856de80 · 856de80
1 parent 023c023
commit 856de80
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 5 deletions.
diff --git a/examples/main.tf b/examples/main.tf
@@ -7,14 +7,16 @@ terraform {
   }
 }
 
-provider "ksql" {
-  url      = ""
-  username = ""
-  password = ""
-}
+provider "ksql" {}
 
 resource "ksql_query" "products_hot_table_table" {
   name  = "products_hot_table"
   type  = "table"
   query = "CREATE TABLE PRODUCTS_HOT_TABLE (ITEM_KEY STRING PRIMARY KEY) WITH (KAFKA_TOPIC = 'PRODUCTS_HOT',VALUE_FORMAT = 'AVRO');"
+
+  credentials {
+    url      = ""
+    username = ""
+    password = ""
+  }
 }
diff --git a/ksql/client/client.go b/ksql/client/client.go
@@ -98,6 +98,10 @@ func (c *Client) makePostKsqlRequest(ctx context.Context, query string) (Respons
 		return nil, err
 	}
 
+	if sc := resp.StatusCode; sc < 200 || sc > 300 {
+		return nil, fmt.Errorf("invalid response status code [%d], body [%s]", sc, string(body))
+	}
+
 	res := Response{}
 	err = json.Unmarshal(body, &res)
 	if err != nil {