Update test

rmoff · Oct 8, 2020 · 4e3b321 · 4e3b321
1 parent 76f9fb1
commit 4e3b321
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/test/main.go b/test/main.go
@@ -10,6 +10,8 @@ import (
 )
 
 const ksqlDBServer string = "http://localhost:8088"
+const ksqlDBUser string = ""
+const ksqlDBPW string = ""
 
 func main() {
 

diff --git a/test/setup.go b/test/setup.go
@@ -8,8 +8,10 @@ import (
 )
 
 func setup() (*ksqldb.Client, error) {
-	//create ksqldb client
-	client := ksqldb.NewClient(ksqlDBServer).Debug()
+
+	//create ksqlDB client
+	client := ksqldb.NewClient(ksqlDBServer, ksqlDBUser, ksqlDBPW).Debug()
+
 	// Create the dummy data connector
 	if err := client.Execute(`
 		CREATE SOURCE CONNECTOR DOGS WITH (